public class MQTTNIOSSLTransport extends NIOSSLTransport
enabledCipherSuites, handshakeInProgress, handshakeStatus, needClientAuth, sslContext, sslEngine, sslSession, status, wantClientAuth
channel, currentBuffer, inputBuffer, nextFrameSize, selection
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 and Description |
---|
MQTTNIOSSLTransport(WireFormat wireFormat,
java.net.Socket socket) |
MQTTNIOSSLTransport(WireFormat wireFormat,
javax.net.SocketFactory socketFactory,
java.net.URI remoteLocation,
java.net.URI localLocation) |
Modifier and Type | Method and Description |
---|---|
protected void |
initializeStreams() |
protected void |
processCommand(java.nio.ByteBuffer plain) |
doHandshake, doStop, finishHandshake, getEnabledCipherSuites, isNeedClientAuth, isWantClientAuth, secureRead, serviceRead, setEnabledCipherSuites, setNeedClientAuth, setSslContext, setWantClientAuth
doStart
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
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
public MQTTNIOSSLTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation) throws java.net.UnknownHostException, java.io.IOException
java.net.UnknownHostException
java.io.IOException
public MQTTNIOSSLTransport(WireFormat wireFormat, java.net.Socket socket) throws java.io.IOException
java.io.IOException
protected void initializeStreams() throws java.io.IOException
initializeStreams
in class NIOSSLTransport
java.io.IOException
protected void processCommand(java.nio.ByteBuffer plain) throws java.lang.Exception
processCommand
in class NIOSSLTransport
java.lang.Exception
Copyright © 2005-2017. All Rights Reserved.