public class MQTTNIOTransport extends TcpTransport
Transport interface for using MQTT over NIOTcpTransport.InitBufferbuffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, initBuffer, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, 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) |
MQTTNIOTransport(WireFormat wireFormat,
Socket socket,
TcpTransport.InitBuffer initBuffer) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
protected void |
initializeStreams() |
protected void |
processBuffer(ByteBuffer buffer,
int readSize) |
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, postStop, preStart, 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
IOExceptionpublic MQTTNIOTransport(WireFormat wireFormat, Socket socket, TcpTransport.InitBuffer initBuffer) throws IOException
IOExceptionprotected void initializeStreams() throws IOException
initializeStreams in class TcpTransportIOExceptionprotected void processBuffer(ByteBuffer buffer, int readSize) throws Exception
Exceptionprotected void doStart() throws Exception
doStart in class TcpTransportExceptionprotected void doStop(ServiceStopper stopper) throws Exception
doStop in class TcpTransportExceptionCopyright © 2005–2016 The Apache Software Foundation. All rights reserved.