Skip to content

Commit 1095fcf

Browse files
committed
Remove deprecated ConcurrentMessageProcessor.startProcessing
use ConcurrentMessageProcessor.beginProcessing instead Fixes #922
1 parent 9b5b259 commit 1095fcf

File tree

2 files changed

+1
-17
lines changed

2 files changed

+1
-17
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ Breaking API changes:
1616
* Remove deprecated factories [#878](https://github.com/eclipse-lsp4j/lsp4j/issues/878)
1717
* Remove deprecated ResponseErrorCode.serverNotInitialized, use ResponseErrorCode.ServerNotInitialized instead [#879](https://github.com/eclipse-lsp4j/lsp4j/issues/879)
1818
* Remove deprecated org.eclipse.lsp4j.websocket. Please upgrade to using Jakarta or remain with LSP4J version 0.x.x [#647](https://github.com/eclipse-lsp4j/lsp4j/issues/647)
19+
* Remove deprecated ConcurrentMessageProcessor.startProcessing, use ConcurrentMessageProcessor.beginProcessing instead [#922](https://github.com/eclipse-lsp4j/lsp4j/issues/922)
1920

2021
japicmp report: <https://download.eclipse.org/lsp4j/builds/main/japicmp-report/>
2122

org.eclipse.lsp4j.jsonrpc/src/main/java/org/eclipse/lsp4j/jsonrpc/json/ConcurrentMessageProcessor.java

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -29,23 +29,6 @@
2929
*/
3030
public class ConcurrentMessageProcessor implements Runnable {
3131

32-
/**
33-
* Start a thread that listens for messages in the message producer and forwards them to the message consumer.
34-
*
35-
* @param messageProducer - produces messages, e.g. by reading from an input channel
36-
* @param messageConsumer - processes messages and potentially forwards them to other consumers
37-
* @param executorService - the thread is started using this service
38-
* @return a future that is resolved when the started thread is terminated, e.g. by closing a stream
39-
* @deprecated Please use the non-static {@link #beginProcessing} instead.
40-
*/
41-
@Deprecated
42-
public static Future<Void> startProcessing(MessageProducer messageProducer, MessageConsumer messageConsumer,
43-
ExecutorService executorService) {
44-
final var reader = new ConcurrentMessageProcessor(messageProducer, messageConsumer);
45-
final Future<?> result = executorService.submit(reader);
46-
return wrapFuture(result, messageProducer);
47-
}
48-
4932
public static Future<Void> wrapFuture(Future<?> result, MessageProducer messageProducer) {
5033
return new Future<>() {
5134

0 commit comments

Comments
 (0)