Class AutoInitNioSSLTransport
- java.lang.Object
-
- org.apache.activemq.util.ServiceSupport
-
- org.apache.activemq.transport.TransportSupport
-
- org.apache.activemq.transport.TransportThreadSupport
-
- org.apache.activemq.transport.tcp.TcpTransport
-
- org.apache.activemq.transport.nio.NIOTransport
-
- org.apache.activemq.transport.nio.NIOSSLTransport
-
- org.apache.activemq.transport.nio.AutoInitNioSSLTransport
-
public class AutoInitNioSSLTransport extends NIOSSLTransport
This transport initializes the SSLEngine and reads the first command before handing off to the detected transport.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.activemq.transport.tcp.TcpTransport
TcpTransport.InitBuffer
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.transport.nio.NIOSSLTransport
enabledCipherSuites, enabledProtocols, handshakeInProgress, handshakeStatus, initialized, needClientAuth, sslContext, sslEngine, sslSession, status, taskRunnerFactory, verifyHostName, wantClientAuth
-
Fields inherited from class org.apache.activemq.transport.nio.NIOTransport
channel, currentBuffer, inputBuffer, nextFrameSize, selection
-
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport
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 Summary
Constructors Constructor Description AutoInitNioSSLTransport(WireFormat wireFormat, Socket socket)
AutoInitNioSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doOpenWireInit()
void
doStart()
protected void
doStop(ServiceStopper stopper)
ByteBuffer
getInputBuffer()
byte[]
getReadData()
AtomicInteger
getReadSize()
SSLEngine
getSslSession()
protected void
initializeStreams()
protected void
processCommand(ByteBuffer plain)
void
serviceRead()
void
setSslContext(SSLContext sslContext)
-
Methods inherited from class org.apache.activemq.transport.nio.NIOSSLTransport
doConsume, doHandshake, doInit, finishHandshake, getEnabledCipherSuites, getEnabledProtocols, getPeerCertificates, isNeedClientAuth, isVerifyHostName, isWantClientAuth, secureRead, setEnabledCipherSuites, setEnabledProtocols, setNeedClientAuth, setVerifyHostName, setWantClientAuth
-
Methods inherited from class org.apache.activemq.transport.nio.NIOTransport
readFromBuffer
-
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransport
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
-
Methods inherited from class org.apache.activemq.transport.TransportThreadSupport
getStackSize, isDaemon, setDaemon, setStackSize
-
Methods inherited from class org.apache.activemq.transport.TransportSupport
asyncRequest, checkStarted, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
-
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.activemq.transport.Transport
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
-
-
-
-
Constructor Detail
-
AutoInitNioSSLTransport
public AutoInitNioSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
- Throws:
UnknownHostException
IOException
-
AutoInitNioSSLTransport
public AutoInitNioSSLTransport(WireFormat wireFormat, Socket socket) throws IOException
- Throws:
IOException
-
-
Method Detail
-
setSslContext
public void setSslContext(SSLContext sslContext)
- Overrides:
setSslContext
in classNIOSSLTransport
-
getInputBuffer
public ByteBuffer getInputBuffer()
-
initializeStreams
protected void initializeStreams() throws IOException
- Overrides:
initializeStreams
in classNIOSSLTransport
- Throws:
IOException
-
doOpenWireInit
protected void doOpenWireInit() throws Exception
- Overrides:
doOpenWireInit
in classNIOSSLTransport
- Throws:
Exception
-
getSslSession
public SSLEngine getSslSession()
-
getReadData
public byte[] getReadData()
-
getReadSize
public AtomicInteger getReadSize()
-
serviceRead
public void serviceRead()
- Overrides:
serviceRead
in classNIOSSLTransport
-
processCommand
protected void processCommand(ByteBuffer plain) throws Exception
- Overrides:
processCommand
in classNIOSSLTransport
- Throws:
Exception
-
doStart
public void doStart() throws Exception
- Overrides:
doStart
in classNIOSSLTransport
- Throws:
Exception
-
doStop
protected void doStop(ServiceStopper stopper) throws Exception
- Overrides:
doStop
in classNIOSSLTransport
- Throws:
Exception
-
-