public class WebsocketConnection extends MessageInbound implements MessageSenderListener
Modifier and Type | Class and Description |
---|---|
(package private) class |
WebsocketConnection.BatchExperiment |
(package private) class |
WebsocketConnection.GeppettoModelAPIParameters |
(package private) class |
WebsocketConnection.GetScript |
(package private) class |
WebsocketConnection.NewExperiment |
(package private) class |
WebsocketConnection.ReceivedObject |
(package private) class |
WebsocketConnection.RunnableQueryDT |
Modifier and Type | Field and Description |
---|---|
protected ApplicationContext |
applicationContext |
private ConnectionHandler |
connectionHandler |
private java.lang.String |
connectionID |
private IGeppettoManager |
geppettoManager |
private static Log |
logger |
private MessageSender |
messageSender |
private DefaultMessageSenderFactory |
messageSenderFactory |
Constructor and Description |
---|
WebsocketConnection() |
Modifier and Type | Method and Description |
---|---|
private java.util.List<RunnableQuery> |
convertRunnableQueriesDataTransferModel(java.util.List<WebsocketConnection.RunnableQueryDT> runnableQueries) |
java.lang.String |
getConnectionID() |
void |
handleMessageSenderEvent(MessageSenderEvent event)
Handle events from the message sender.
|
protected void |
onBinaryMessage(java.nio.ByteBuffer message) |
protected void |
onClose(int status) |
protected void |
onOpen(WsOutbound outbound) |
protected void |
onTextMessage(java.nio.CharBuffer message)
Receives message(s) from client.
|
void |
sendBinaryMessage(java.lang.String requestID,
java.nio.file.Path path) |
void |
sendMessage(java.lang.String requestID,
OutboundMessages type,
java.lang.String message) |
private static Log logger
private ConnectionHandler connectionHandler
private java.lang.String connectionID
protected ApplicationContext applicationContext
private DefaultMessageSenderFactory messageSenderFactory
private MessageSender messageSender
private IGeppettoManager geppettoManager
protected void onOpen(WsOutbound outbound)
protected void onClose(int status)
protected void onBinaryMessage(java.nio.ByteBuffer message) throws java.io.IOException
java.io.IOException
public void sendMessage(java.lang.String requestID, OutboundMessages type, java.lang.String message)
requestID
- type
- message
- public void sendBinaryMessage(java.lang.String requestID, java.nio.file.Path path)
requestID
- type
- message
- protected void onTextMessage(java.nio.CharBuffer message) throws java.io.IOException
java.io.IOException
private java.util.List<RunnableQuery> convertRunnableQueriesDataTransferModel(java.util.List<WebsocketConnection.RunnableQueryDT> runnableQueries)
runnableQueries
- public java.lang.String getConnectionID()
public void handleMessageSenderEvent(MessageSenderEvent event)
handleMessageSenderEvent
in interface MessageSenderListener
event
- event from the message sender.