Package org.apache.activemq.transport.stomp

Class StompNIOSSLTransport

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.stomp.StompNIOSSLTransport

All Implemented Interfaces:

Runnable, Service, Transport

public class StompNIOSSLTransport
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
StompNIOSSLTransport(WireFormat wireFormat, Socket socket)
StompNIOSSLTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer)
StompNIOSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)

Method Summary

Modifier and Type	Method	Description
void	doConsume(Object command)	Overriding in order to add the client's certificates to ConnectionInfo Commands.
protected void	doInit()
String	getRemoteAddress()
protected void	initializeStreams()
protected void	processCommand(ByteBuffer plain)

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

doHandshake, doOpenWireInit, doStart, doStop, finishHandshake, getEnabledCipherSuites, getEnabledProtocols, getPeerCertificates, isNeedClientAuth, isVerifyHostName, isWantClientAuth, secureRead, 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, 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.Service

start

Methods inherited from interface org.apache.activemq.transport.Transport

asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs

Constructor Detail

StompNIOSSLTransport

public StompNIOSSLTransport(WireFormat wireFormat,
                            SocketFactory socketFactory,
                            URI remoteLocation,
                            URI localLocation)
                     throws UnknownHostException,
                            IOException

Throws:

UnknownHostException

IOException

StompNIOSSLTransport

public StompNIOSSLTransport(WireFormat wireFormat,
                            Socket socket)
                     throws IOException

Throws:

IOException

StompNIOSSLTransport

public StompNIOSSLTransport(WireFormat wireFormat,
                            Socket socket,
                            SSLEngine engine,
                            TcpTransport.InitBuffer initBuffer,
                            ByteBuffer inputBuffer)
                     throws IOException

Throws:

IOException

Method Detail

getRemoteAddress

public String getRemoteAddress()

Specified by:

getRemoteAddress in interface Transport

Overrides:

getRemoteAddress in class TcpTransport

Returns:

the remote address for this connection

initializeStreams

protected void initializeStreams()
                          throws IOException

Overrides:

initializeStreams in class NIOSSLTransport

Throws:

IOException

processCommand

protected void processCommand(ByteBuffer plain)
                       throws Exception

Overrides:

processCommand in class NIOSSLTransport

Throws:

Exception

doConsume

public void doConsume(Object command)

Description copied from class: NIOSSLTransport

Overriding in order to add the client's certificates to ConnectionInfo Commands.

Overrides:

doConsume in class NIOSSLTransport

Parameters:

command - The Command coming in.

doInit

protected void doInit()
               throws Exception

Overrides:

doInit in class NIOSSLTransport

Throws:

Exception