public class StompClient extends PlainClient
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 |
|---|
StompClient(Reactor reactor,
Selector selector,
String hostname,
int port) |
| Modifier and Type | Method and Description |
|---|---|
protected OneTimeCallback |
getPostConnectCallback() |
boolean |
isInInit() |
protected void |
postConnect(OneTimeCallback callback)
Transport specific post connection functionality.
|
void |
sendMessage(byte[] message)
Sends message using provided byte array.
|
postDisconnect, 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, setClientPolicy, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeatpublic StompClient(Reactor reactor, Selector selector, String hostname, int port) throws ClientConnectionException
ClientConnectionExceptionpublic void sendMessage(byte[] message)
ReactorClientsendMessage in class ReactorClientmessage - - content of the message to sent.protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClientpostConnect in class PlainClientcallback - - callback which is executed after connection is estabilished.ClientConnectionException - when issues with connection.protected OneTimeCallback getPostConnectCallback()
getPostConnectCallback in class ReactorClientOneTimeCallback or null. The callback is executed
after the connection is established.public boolean isInInit()
isInInit in class ReactorClienttrue when connection initialization is in progress like
SSL hand shake. false when connection is initialized.Copyright © 2018. All Rights Reserved.