public class SSLStompListener extends SSLStompClient implements Sender
ReactorClient.MessageListener
connected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIds
BUFFER_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, isInInit
createSSLEngine, getPeerCertificates, postDisconnect, process, read, updateInterestedOps
buildNetworkResponse, close, emitOnMessageReceived, getEventQueue, getRequestQueue, getResponseQueue, processIncoming, send, sendHeartbeat, sendNow, updatePolicyWithHeartbeat, validate
addEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getRetryPolicy, getSelectionKey, isOpen, performAction, processOutgoing, removeEventListener, scheduleTask, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeat
public SSLStompListener(Reactor reactor, Selector selector, String hostname, int port, SocketChannel socketChannel, SSLContext sslContext) throws ClientConnectionException
ClientConnectionException
public void sendMessage(byte[] message)
ReactorClient
sendMessage
in class SSLStompClient
message
- - content of the message to sent.public void setClientPolicy(ClientPolicy policy)
setClientPolicy
in class ReactorClient
protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClient
postConnect
in class SSLStompClient
callback
- - callback which is executed after connection is estabilished.ClientConnectionException
- when issues with connection.Copyright © 2016. All rights reserved.