public class StompNIOSSLTransport extends NIOSSLTransport
TcpTransport.InitBuffer
enabledCipherSuites, enabledProtocols, handshakeInProgress, handshakeStatus, initialized, needClientAuth, sslContext, sslEngine, sslSession, status, taskRunnerFactory, verifyHostName, wantClientAuth
channel, currentBuffer, inputBuffer, nextFrameSize, selection
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, initBuffer, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, socketOptions, 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, isVerifyHostName, isWantClientAuth, secureRead, serviceRead, setEnabledCipherSuites, setEnabledProtocols, setNeedClientAuth, setSslContext, setVerifyHostName, setWantClientAuth
readFromBuffer
closeStreams, 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, toString
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
public StompNIOSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostException
IOException
public StompNIOSSLTransport(WireFormat wireFormat, Socket socket) throws IOException
IOException
public StompNIOSSLTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer) throws IOException
IOException
protected void initializeStreams() throws IOException
initializeStreams
in class NIOSSLTransport
IOException
protected void processCommand(ByteBuffer plain) throws Exception
processCommand
in class NIOSSLTransport
Exception
public void doConsume(Object command)
NIOSSLTransport
doConsume
in class NIOSSLTransport
command
- The Command coming in.protected void doInit() throws Exception
doInit
in class NIOSSLTransport
Exception
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.