public class SSLStompClient extends SSLClient
ReactorClient.MessageListenerlog, nioEngine, selectorconnected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIdsBUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, ibuff, key, outbox, policy, reactor| Constructor and Description |
|---|
SSLStompClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SSLContext sslContext) |
| 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.
|
createSSLEngine, 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, setClientPolicy, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeatpublic SSLStompClient(Reactor reactor, Selector selector, String hostname, int port, SSLContext sslContext) throws ClientConnectionException
ClientConnectionExceptionpublic void sendMessage(byte[] message)
throws ClientConnectionException
ReactorClientsendMessage in class ReactorClientmessage - - content of the message to sent.ClientConnectionException - when issues with connection.protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClientpostConnect in class SSLClientcallback - - 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.