public class StompListener extends StompClient implements Sender
ReactorClient.MessageListener
selector
connected, headerBuffer, message, REQUEST_QUEUE, RESPONSE_QUEUE, subscribed, subscribtionId
BUFFER_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.
|
getPostConnectCallback, isInInit
postDisconnect, read, updateInterestedOps
buildNetworkResponse, close, emitOnMessageReceived, processIncoming, send
addEventListener, connect, disconnect, emitOnMessageReceived, getClientId, getHostname, getRetryPolicy, getSelectionKey, isOpen, process, processOutgoing, removeEventListener, scheduleTask, setRetryPolicy, updateLastHeartbeat
public StompListener(Reactor reactor, Selector selector, String hostname, int port, SocketChannel socketChannel) throws ClientConnectionException
ClientConnectionException
public void sendMessage(byte[] message)
ReactorClient
sendMessage
in class StompClient
message
- - content of the message to sent.protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClient
postConnect
in class StompClient
ClientConnectionException
- when issues with connection.Copyright © 2015. All Rights Reserved.