org.apache.activemq.transport.nio

Class NIOSSLTransport

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

All Implemented Interfaces:

java.lang.Runnable, Service, Transport

Direct Known Subclasses:

MQTTNIOSSLTransport, StompNIOSSLTransport

public class NIOSSLTransport
extends NIOTransport

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String[]	enabledCipherSuites
protected boolean	handshakeInProgress
protected javax.net.ssl.SSLEngineResult.HandshakeStatus	handshakeStatus
protected boolean	needClientAuth
protected javax.net.ssl.SSLContext	sslContext
protected javax.net.ssl.SSLEngine	sslEngine
protected javax.net.ssl.SSLSession	sslSession
protected javax.net.ssl.SSLEngineResult.Status	status
protected boolean	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, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat

Constructor Summary

Constructors

Constructor and Description
NIOSSLTransport(WireFormat wireFormat, java.net.Socket socket)
NIOSSLTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doHandshake()
protected void	doStop(ServiceStopper stopper)
protected void	finishHandshake()
java.lang.String[]	getEnabledCipherSuites()
protected void	initializeStreams()
boolean	isNeedClientAuth()
boolean	isWantClientAuth()
protected void	processCommand(java.nio.ByteBuffer plain)
protected int	secureRead(java.nio.ByteBuffer plain)
protected void	serviceRead()
void	setEnabledCipherSuites(java.lang.String[] enabledCipherSuites)
void	setNeedClientAuth(boolean needClientAuth)
void	setSslContext(javax.net.ssl.SSLContext sslContext)
void	setWantClientAuth(boolean wantClientAuth)

Methods inherited from class org.apache.activemq.transport.nio.NIOTransport

doStart

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, 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, doConsume, 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, 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

Methods inherited from interface org.apache.activemq.Service

start

Field Detail

needClientAuth

protected boolean needClientAuth

wantClientAuth

protected boolean wantClientAuth

enabledCipherSuites

protected java.lang.String[] enabledCipherSuites

sslContext

protected javax.net.ssl.SSLContext sslContext

sslEngine

protected javax.net.ssl.SSLEngine sslEngine

sslSession

protected javax.net.ssl.SSLSession sslSession

handshakeInProgress

protected boolean handshakeInProgress

status

protected javax.net.ssl.SSLEngineResult.Status status

handshakeStatus

protected javax.net.ssl.SSLEngineResult.HandshakeStatus handshakeStatus

Constructor Detail

NIOSSLTransport

public NIOSSLTransport(WireFormat wireFormat,
               javax.net.SocketFactory socketFactory,
               java.net.URI remoteLocation,
               java.net.URI localLocation)
                throws java.net.UnknownHostException,
                       java.io.IOException

Throws:

java.net.UnknownHostException

java.io.IOException

NIOSSLTransport

public NIOSSLTransport(WireFormat wireFormat,
               java.net.Socket socket)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

setSslContext

public void setSslContext(javax.net.ssl.SSLContext sslContext)

initializeStreams

protected void initializeStreams()
                          throws java.io.IOException

Overrides:

initializeStreams in class NIOTransport

Throws:

java.io.IOException

finishHandshake

protected void finishHandshake()
                        throws java.lang.Exception

Throws:

java.lang.Exception

serviceRead

protected void serviceRead()

Overrides:

serviceRead in class NIOTransport

processCommand

protected void processCommand(java.nio.ByteBuffer plain)
                       throws java.lang.Exception

Throws:

java.lang.Exception

secureRead

protected int secureRead(java.nio.ByteBuffer plain)
                  throws java.lang.Exception

Throws:

java.lang.Exception

doHandshake

protected void doHandshake()
                    throws java.lang.Exception

Throws:

java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception

Overrides:

doStop in class NIOTransport

Throws:

java.lang.Exception

isNeedClientAuth

public boolean isNeedClientAuth()

setNeedClientAuth

public void setNeedClientAuth(boolean needClientAuth)

isWantClientAuth

public boolean isWantClientAuth()

setWantClientAuth

public void setWantClientAuth(boolean wantClientAuth)

getEnabledCipherSuites

public java.lang.String[] getEnabledCipherSuites()

setEnabledCipherSuites

public void setEnabledCipherSuites(java.lang.String[] enabledCipherSuites)