Class AmqpNioSslTransport
-
public class AmqpNioSslTransport extends NIOSSLTransport
-
-
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 AmqpNioSslTransport(WireFormat wireFormat, Socket socket)
AmqpNioSslTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer)
AmqpNioSslTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doInit()
protected void
initializeStreams()
protected void
processCommand(ByteBuffer plain)
protected int
secureRead(ByteBuffer plain)
-
Methods inherited from class org.apache.activemq.transport.nio.NIOSSLTransport
doConsume, doHandshake, doOpenWireInit, doStart, doStop, finishHandshake, getEnabledCipherSuites, getEnabledProtocols, getPeerCertificates, isNeedClientAuth, isVerifyHostName, isWantClientAuth, serviceRead, setEnabledCipherSuites, setEnabledProtocols, setNeedClientAuth, setSslContext, 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
-
AmqpNioSslTransport
public AmqpNioSslTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
- Throws:
UnknownHostException
IOException
-
AmqpNioSslTransport
public AmqpNioSslTransport(WireFormat wireFormat, Socket socket) throws IOException
- Throws:
IOException
-
AmqpNioSslTransport
public AmqpNioSslTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer) throws IOException
- Throws:
IOException
-
-
Method Detail
-
initializeStreams
protected void initializeStreams() throws IOException
- Overrides:
initializeStreams
in classNIOSSLTransport
- Throws:
IOException
-
processCommand
protected void processCommand(ByteBuffer plain) throws Exception
- Overrides:
processCommand
in classNIOSSLTransport
- Throws:
Exception
-
doInit
protected void doInit() throws Exception
- Overrides:
doInit
in classNIOSSLTransport
- Throws:
Exception
-
secureRead
protected int secureRead(ByteBuffer plain) throws Exception
- Overrides:
secureRead
in classNIOSSLTransport
- Throws:
Exception
-
-