public class SSLStompClient extends SSLClient
ReactorClient.MessageListener
connected, headerBuffer, message, REQUEST_QUEUE, RESPONSE_QUEUE, subscribed, subscribtionId
BUFFER_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, postDisconnect, process, read, updateInterestedOps
buildNetworkResponse, close, emitOnMessageReceived, processIncoming, send
addEventListener, connect, disconnect, emitOnMessageReceived, getClientId, getHostname, getRetryPolicy, getSelectionKey, isOpen, processOutgoing, removeEventListener, scheduleTask, setRetryPolicy, updateLastHeartbeat
public SSLStompClient(Reactor reactor, Selector selector, String hostname, int port, SSLContext sslContext) throws ClientConnectionException
ClientConnectionException
public void sendMessage(byte[] message) throws ClientConnectionException
ReactorClient
sendMessage
in class ReactorClient
message
- - content of the message to sent.ClientConnectionException
protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClient
postConnect
in class SSLClient
ClientConnectionException
- when issues with connection.protected OneTimeCallback getPostConnectCallback()
getPostConnectCallback
in class ReactorClient
OneTimeCallback
or null. The callback is executed
after the connection is established.public boolean isInInit()
isInInit
in class ReactorClient
true
when connection initialization is in progress like
SSL hand shake. false
when connection is initialized.Copyright © 2015. All Rights Reserved.