Package org.apache.activemq.transport.mqtt

Class MQTTNIOSSLTransport

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.mqtt.MQTTNIOSSLTransport
All Implemented Interfaces:
Runnable, org.apache.activemq.Service, org.apache.activemq.transport.Transport
public class MQTTNIOSSLTransport 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
    MQTTNIOSSLTransport(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket)
     
    MQTTNIOSSLTransport(org.apache.activemq.wireformat.WireFormat wireFormat, Socket socket, SSLEngine engine, org.apache.activemq.transport.tcp.TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer)
     
    MQTTNIOSSLTransport(org.apache.activemq.wireformat.WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    doInit()
     
    protected void
    initializeStreams()
     
    protected void
    processCommand(ByteBuffer plain)
     

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

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

    • 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

    • doInit

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