public class MQTTNIOTransport extends TcpTransport
Transport interface for using MQTT over NIObuffOut, 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 |
|---|
MQTTNIOTransport(WireFormat wireFormat,
Socket socket) |
MQTTNIOTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
protected void |
initializeStreams() |
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, toStringgetStackSize, isDaemon, setDaemon, setStackSizeasyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIsaddServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, startclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitasyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIspublic MQTTNIOTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostExceptionIOExceptionpublic MQTTNIOTransport(WireFormat wireFormat, Socket socket) throws IOException
IOExceptionprotected void initializeStreams() throws IOException
initializeStreams in class TcpTransportIOExceptionprotected void doStart() throws Exception
doStart in class TcpTransportExceptionprotected void doStop(ServiceStopper stopper) throws Exception
doStop in class TcpTransportExceptionCopyright © 2005–2017. All rights reserved.