Top Description Inners Fields Constructors Methods
org.eclipse.lsp4j.websocket.jakarta

public Class WebSocketMessageConsumer

extends Object
implements MessageConsumer
Class Inheritance
All Implemented Interfaces
org.eclipse.lsp4j.jsonrpc.MessageConsumer
Imports
java.io.IOException, java.util.concurrent.ConcurrentLinkedQueue, java.util.concurrent.atomic.AtomicBoolean, java.util.logging.Level, .Logger, jakarta.websocket.SendHandler, .SendResult, .Session, org.eclipse.lsp4j.jsonrpc.JsonRpcException, .MessageConsumer, org.eclipse.lsp4j.jsonrpc.json.MessageJsonHandler, org.eclipse.lsp4j.jsonrpc.messages.Message
Message consumer that sends messages via a WebSocket session.

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
WebSocketMessageConsumer.WebSocketSendHandler

Field Summary

Modifier and TypeField and Description
private final WebSocketMessageConsumer.WebSocketSendHandler
handler

private final MessageJsonHandler
jsonHandler

private static final Logger
LOG

private final ConcurrentLinkedQueue<String>
messageQueue

private final Session
session

Constructor Summary

AccessConstructor and Description
public
WebSocketMessageConsumer(Session session, MessageJsonHandler jsonHandler)

Method Summary

Modifier and TypeMethod and Description
public void
consume(Message message)

Implements org.eclipse.lsp4j.jsonrpc.MessageConsumer.consume.

Consume a single message.

public Session
getSession()

protected void
sendMessage(String message)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

handlerback to summary
private final WebSocketMessageConsumer.WebSocketSendHandler handler
jsonHandlerback to summary
private final MessageJsonHandler jsonHandler
LOGback to summary
private static final Logger LOG
messageQueueback to summary
private final ConcurrentLinkedQueue<String> messageQueue
sessionback to summary
private final Session session

Constructor Detail

WebSocketMessageConsumerback to summary
public WebSocketMessageConsumer(Session session, MessageJsonHandler jsonHandler)

Method Detail

consumeback to summary
public void consume(Message message)

Implements org.eclipse.lsp4j.jsonrpc.MessageConsumer.consume.

Doc from org.eclipse.lsp4j.jsonrpc.MessageConsumer.consume.

Consume a single message.

Annotations
@Override
getSessionback to summary
public Session getSession()
sendMessageback to summary
protected void sendMessage(String message) throws IOException
org.eclipse.lsp4j.websocket.jakarta back to summary

private Class WebSocketMessageConsumer.WebSocketSendHandler

extends Object
implements SendHandler
Class Inheritance
  • java.lang.Object
  • org.eclipse.lsp4j.websocket.jakarta.WebSocketMessageConsumer.WebSocketSendHandler
All Implemented Interfaces
jakarta.websocket.SendHandler

Field Summary

Modifier and TypeField and Description
private final AtomicBoolean
isSending

Constructor Summary

AccessConstructor and Description
private
WebSocketSendHandler()

Method Summary

Modifier and TypeMethod and Description
pack-priv void
handleNextMessage()

public void
onResult(SendResult result)

Implements jakarta.websocket.SendHandler.onResult.

Called once the message has been transmitted.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

isSendingback to summary
private final AtomicBoolean isSending

Constructor Detail

WebSocketSendHandlerback to summary
private WebSocketSendHandler()

Method Detail

handleNextMessageback to summary
pack-priv void handleNextMessage()
onResultback to summary
public void onResult(SendResult result)

Implements jakarta.websocket.SendHandler.onResult.

Doc from jakarta.websocket.SendHandler.onResult.

Called once the message has been transmitted.

Annotations
@Override