Class AutoNIOTransport
- java.lang.Object
-
- org.apache.activemq.util.ServiceSupport
-
- org.apache.activemq.transport.TransportSupport
-
- org.apache.activemq.transport.TransportThreadSupport
-
- org.apache.activemq.transport.tcp.TcpTransport
-
- org.apache.activemq.transport.nio.NIOTransport
-
- org.apache.activemq.transport.auto.nio.AutoNIOTransport
-
public class AutoNIOTransport extends NIOTransport
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.activemq.transport.tcp.TcpTransport
TcpTransport.InitBuffer
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.transport.nio.NIOTransport
channel, currentBuffer, inputBuffer, nextFrameSize, selection
-
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport
buffOut, 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 Summary
Constructors Constructor Description AutoNIOTransport(WireFormat wireFormat, Socket socket)
AutoNIOTransport(WireFormat format, Socket socket, TcpTransport.InitBuffer initBuffer)
AutoNIOTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected int
readFromBuffer()
Read from the initial buffer if it is set-
Methods inherited from class org.apache.activemq.transport.nio.NIOTransport
doStart, doStop, initializeStreams, serviceRead
-
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransport
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, toString
-
Methods inherited from class org.apache.activemq.transport.TransportThreadSupport
getStackSize, isDaemon, setDaemon, setStackSize
-
Methods inherited from class org.apache.activemq.transport.TransportSupport
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
-
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.activemq.transport.Transport
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
-
-
-
-
Constructor Detail
-
AutoNIOTransport
public AutoNIOTransport(WireFormat format, Socket socket, TcpTransport.InitBuffer initBuffer) throws IOException
- Throws:
IOException
-
AutoNIOTransport
public AutoNIOTransport(WireFormat wireFormat, Socket socket) throws IOException
- Throws:
IOException
-
AutoNIOTransport
public AutoNIOTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
- Throws:
UnknownHostException
IOException
-
-
Method Detail
-
readFromBuffer
protected int readFromBuffer() throws IOException
Read from the initial buffer if it is set- Overrides:
readFromBuffer
in classNIOTransport
- Throws:
IOException
-
-