org.apache.activemq.transport.stomp
Class StompNIOSSLTransport

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.transport.TransportSupport
          extended by org.apache.activemq.transport.TransportThreadSupport
              extended by org.apache.activemq.transport.tcp.TcpTransport
                  extended by org.apache.activemq.transport.nio.NIOTransport
                      extended by org.apache.activemq.transport.nio.NIOSSLTransport
                          extended by org.apache.activemq.transport.stomp.StompNIOSSLTransport
All Implemented Interfaces:
Runnable, Service, Transport

public class StompNIOSSLTransport
extends NIOSSLTransport


Field Summary
 
Fields inherited from class org.apache.activemq.transport.nio.NIOSSLTransport
enabledCipherSuites, handshakeInProgress, handshakeStatus, needClientAuth, sslContext, sslEngine, sslSession, status, taskRunnerFactory, 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, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
 
Constructor Summary
StompNIOSSLTransport(WireFormat wireFormat, Socket socket)
           
StompNIOSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)
           
 
Method Summary
 void doConsume(Object command)
          Overriding in order to add the client's certificates to ConnectionInfo Commands.
protected  void initializeStreams()
           
protected  void processCommand(ByteBuffer plain)
           
 
Methods inherited from class org.apache.activemq.transport.nio.NIOSSLTransport
doHandshake, doStart, doStop, finishHandshake, getEnabledCipherSuites, getPeerCertificates, isNeedClientAuth, isWantClientAuth, secureRead, serviceRead, setEnabledCipherSuites, setNeedClientAuth, setSslContext, setWantClientAuth
 
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, 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
 
Methods inherited from interface org.apache.activemq.Service
start
 

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
Method Detail

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.


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.