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, org.apache.activemq.Service, org.apache.activemq.transport.Transport
public class StompNIOSSLTransport extends org.apache.activemq.transport.nio.NIOSSLTransport

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.activemq.transport.tcp.TcpTransport

    org.apache.activemq.transport.tcp.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(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket)
     
    StompNIOSSLTransport(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket, SSLEngine engine, org.apache.activemq.transport.tcp.TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer)
     
    StompNIOSSLTransport(org.apache.activemq.wireformat.WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    doConsume(Object command)
     
    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, handleHandshakeUpdate, 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 Details

  • Method Details

    • getRemoteAddress

      public String getRemoteAddress()
      Specified by:
      getRemoteAddress in interface org.apache.activemq.transport.Transport
      Overrides:
      getRemoteAddress in class org.apache.activemq.transport.tcp.TcpTransport

    • initializeStreams

      protected void initializeStreams() throws IOException
      Overrides:
      initializeStreams in class org.apache.activemq.transport.nio.NIOSSLTransport
      Throws:
      IOException

    • processCommand

      protected void processCommand(ByteBuffer plain) throws Exception
      Overrides:
      processCommand in class org.apache.activemq.transport.nio.NIOSSLTransport
      Throws:
      Exception

    • doConsume

      public void doConsume(Object command)
      Overrides:
      doConsume in class org.apache.activemq.transport.nio.NIOSSLTransport

    • doInit

      protected void doInit() throws Exception
      Overrides:
      doInit in class org.apache.activemq.transport.nio.NIOSSLTransport
      Throws:
      Exception