public class StompNIOTransport extends TcpTransport
Transport interface for using Stomp 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 |
|---|
StompNIOTransport(WireFormat wireFormat,
Socket socket) |
StompNIOTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
StompNIOTransport(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, getPeerCertificates, 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, 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 StompNIOTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostExceptionIOExceptionpublic StompNIOTransport(WireFormat wireFormat, Socket socket) throws IOException
IOExceptionpublic StompNIOTransport(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–2017 The Apache Software Foundation. All rights reserved.