Package | Description |
---|---|
eneter.messaging.dataprocessing.messagequeueing |
Helper to queue and process messages with a working thread.
|
eneter.messaging.messagingsystems.websocketmessagingsystem |
Communication via Websockets.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkingThread.registerMessageHandler(IMethod1<TMessage> messageHandler)
Registers the method handling messages from the queue and starts the thread reading messages from the queue.
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketListener.startListening(IMethod1<IWebSocketClientContext> connectionHandler)
Starts listening.
|