public class AmqpNioTransport extends TcpTransport
Transport interface for using AMQP over NIOTcpTransport.InitBufferbuffOut, 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 and Description |
|---|
AmqpNioTransport(WireFormat wireFormat,
Socket socket) |
AmqpNioTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
AmqpNioTransport(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 AmqpNioTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostExceptionIOExceptionpublic AmqpNioTransport(WireFormat wireFormat, Socket socket) throws IOException
IOExceptionpublic AmqpNioTransport(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–2019 The Apache Software Foundation. All rights reserved.