public abstract class SSLClient extends StompCommonClient
ReactorClient implementation to provide encrypted communication.ReactorClient.MessageListener| Modifier and Type | Field and Description |
|---|---|
protected static org.slf4j.Logger |
log |
protected SSLEngineNioHelper |
nioEngine |
protected Selector |
selector |
connected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIdsBUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, ibuff, key, outbox, policy, reactor| Constructor and Description |
|---|
SSLClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SSLContext sslctx) |
SSLClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SSLContext sslctx,
SocketChannel socketChannel) |
| Modifier and Type | Method and Description |
|---|---|
protected SSLEngine |
createSSLEngine(boolean clientMode) |
List<Certificate> |
getPeerCertificates() |
protected void |
postConnect(OneTimeCallback callback)
Transport specific post connection functionality.
|
void |
postDisconnect()
Cleans resources after disconnect.
|
void |
process() |
protected int |
read(ByteBuffer buff)
Reads provided buffer.
|
void |
updateInterestedOps()
Updates selection key's operation set.
|
buildNetworkResponse, clean, close, emitOnMessageReceived, getEventQueue, getRequestQueue, getResponseQueue, processIncoming, send, sendHeartbeat, sendNow, updatePolicyWithHeartbeat, validateaddEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getPostConnectCallback, getRetryPolicy, getSelectionKey, isInInit, isOpen, performAction, processOutgoing, removeEventListener, scheduleTask, sendMessage, setClientPolicy, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeatprotected static org.slf4j.Logger log
protected final Selector selector
protected SSLEngineNioHelper nioEngine
public SSLClient(Reactor reactor, Selector selector, String hostname, int port, SSLContext sslctx) throws ClientConnectionException
ClientConnectionExceptionpublic SSLClient(Reactor reactor, Selector selector, String hostname, int port, SSLContext sslctx, SocketChannel socketChannel) throws ClientConnectionException
ClientConnectionExceptionprotected SSLEngine createSSLEngine(boolean clientMode)
public void updateInterestedOps()
ReactorClientupdateInterestedOps in class ReactorClientprotected int read(ByteBuffer buff) throws IOException
ReactorClientread in class ReactorClientbuff - provided buffer to be read.IOException - when networking issue occurs.public void process()
throws IOException,
ClientConnectionException
process in class ReactorClientIOExceptionClientConnectionExceptionprotected void postConnect(OneTimeCallback callback) throws ClientConnectionException
ReactorClientpostConnect in class ReactorClientcallback - - callback which is executed after connection is estabilished.ClientConnectionException - when issues with connection.public void postDisconnect()
ReactorClientpostDisconnect in class ReactorClientpublic List<Certificate> getPeerCertificates()
getPeerCertificates in class ReactorClientCopyright © 2018. All Rights Reserved.