public class StompNIOSSLTransport extends NIOSSLTransport
TcpTransport.InitBufferenabledCipherSuites, enabledProtocols, handshakeInProgress, handshakeStatus, initialized, needClientAuth, sslContext, sslEngine, sslSession, status, taskRunnerFactory, wantClientAuthchannel, currentBuffer, inputBuffer, nextFrameSize, selectionbuffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, initBuffer, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat| Constructor and Description |
|---|
StompNIOSSLTransport(WireFormat wireFormat,
Socket socket) |
StompNIOSSLTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
StompNIOSSLTransport(WireFormat wireFormat,
Socket socket,
SSLEngine engine,
TcpTransport.InitBuffer initBuffer,
ByteBuffer inputBuffer) |
| Modifier and Type | Method and Description |
|---|---|
void |
doConsume(Object command)
Overriding in order to add the client's certificates to ConnectionInfo Commands.
|
protected void |
doInit() |
protected void |
initializeStreams() |
protected void |
processCommand(ByteBuffer plain) |
doHandshake, doOpenWireInit, doStart, doStop, finishHandshake, getEnabledCipherSuites, getEnabledProtocols, getPeerCertificates, isNeedClientAuth, isWantClientAuth, secureRead, serviceRead, setEnabledCipherSuites, setEnabledProtocols, setNeedClientAuth, setSslContext, setWantClientAuthreadFromBuffercloseStreams, connect, doRun, getConnectionTimeout, getDiffServ, getIoBufferSize, getJmxPort, getKeepAlive, getLogWriterName, getMinmumWireFormatVersion, getReceiveCounter, getRemoteAddress, getSocketBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTypeOfService, getWireFormat, initialiseSocket, isCloseAsync, isDynamicManagement, isStartLogging, isTrace, isUseLocalHost, narrow, oneway, readCommand, resolveHostName, run, setCloseAsync, setConnectionTimeout, setDiffServ, setDynamicManagement, setIoBufferSize, setJmxPort, setKeepAlive, setLogWriterName, setMinmumWireFormatVersion, setPeerCertificates, setSocketBufferSize, setSocketOptions, setSoLinger, setSoTimeout, setStartLogging, setTcpNoDelay, setTrace, setTypeOfService, setUseLocalHost, stop, toStringgetStackSize, isDaemon, setDaemon, setStackSizeasyncRequest, checkStarted, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIsaddServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, startclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitasyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIspublic StompNIOSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostExceptionIOExceptionpublic StompNIOSSLTransport(WireFormat wireFormat, Socket socket) throws IOException
IOExceptionpublic StompNIOSSLTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer) throws IOException
IOExceptionprotected void initializeStreams() throws IOException
initializeStreams in class NIOSSLTransportIOExceptionprotected void processCommand(ByteBuffer plain) throws Exception
processCommand in class NIOSSLTransportExceptionpublic void doConsume(Object command)
NIOSSLTransportdoConsume in class NIOSSLTransportcommand - The Command coming in.protected void doInit() throws Exception
doInit in class NIOSSLTransportExceptionCopyright © 2005–2017 The Apache Software Foundation. All rights reserved.