public class StompListener extends StompClient implements Sender
ReactorClient.MessageListenerselectorconnected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIdsBUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, ibuff, key, outbox, policy, reactor| Constructor and Description |
|---|
StompListener(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel socketChannel) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
postConnect(OneTimeCallback callback)
Transport specific post connection functionality.
|
void |
sendMessage(byte[] message)
Sends message using provided byte array.
|
void |
setClientPolicy(ClientPolicy policy) |
getPostConnectCallback, isInInitpostDisconnect, read, updateInterestedOpsbuildNetworkResponse, clean, close, emitOnMessageReceived, getEventQueue, getRequestQueue, getResponseQueue, processIncoming, send, sendHeartbeat, sendNow, updatePolicyWithHeartbeat, validateaddEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getPeerCertificates, getRetryPolicy, getSelectionKey, isOpen, performAction, process, processOutgoing, removeEventListener, scheduleTask, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeatpublic StompListener(Reactor reactor, Selector selector, String hostname, int port, SocketChannel socketChannel) throws ClientConnectionException
ClientConnectionExceptionpublic void setClientPolicy(ClientPolicy policy)
setClientPolicy in class ReactorClientpublic void sendMessage(byte[] message)
ReactorClientsendMessage in class StompClientmessage - - content of the message to sent.protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClientpostConnect in class StompClientcallback - - callback which is executed after connection is estabilished.ClientConnectionException - when issues with connection.Copyright © 2018. All Rights Reserved.