public class SSLStompListener extends SSLStompClient implements Sender
ReactorClient.MessageListenerconnected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIdsBUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, ibuff, key, outbox, policy, reactor| Constructor and Description |
|---|
SSLStompListener(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel socketChannel,
SSLContext sslContext) |
| 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, isInInitcreateSSLEngine, getPeerCertificates, postDisconnect, process, read, updateInterestedOpsbuildNetworkResponse, clean, close, emitOnMessageReceived, getEventQueue, getRequestQueue, getResponseQueue, processIncoming, send, sendHeartbeat, sendNow, updatePolicyWithHeartbeat, validateaddEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getRetryPolicy, getSelectionKey, isOpen, performAction, processOutgoing, removeEventListener, scheduleTask, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeatpublic SSLStompListener(Reactor reactor, Selector selector, String hostname, int port, SocketChannel socketChannel, SSLContext sslContext) throws ClientConnectionException
ClientConnectionExceptionpublic void sendMessage(byte[] message)
ReactorClientsendMessage in class SSLStompClientmessage - - content of the message to sent.public void setClientPolicy(ClientPolicy policy)
setClientPolicy in class ReactorClientprotected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClientpostConnect in class SSLStompClientcallback - - callback which is executed after connection is estabilished.ClientConnectionException - when issues with connection.Copyright © 2018. All Rights Reserved.