org.apache.activemq.transport.nio
Class NIOTransport
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
- All Implemented Interfaces:
- java.lang.Runnable, Service, Transport
- Direct Known Subclasses:
- NIOSSLTransport
public class NIOTransport
- extends TcpTransport
An implementation of the Transport
interface using raw tcp/ip
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport |
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat |
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransport |
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, toString |
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 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 |
Methods inherited from interface org.apache.activemq.Service |
start |
channel
protected java.nio.channels.SocketChannel channel
selection
protected SelectorSelection selection
inputBuffer
protected java.nio.ByteBuffer inputBuffer
currentBuffer
protected java.nio.ByteBuffer currentBuffer
nextFrameSize
protected int nextFrameSize
NIOTransport
public NIOTransport(WireFormat wireFormat,
javax.net.SocketFactory socketFactory,
java.net.URI remoteLocation,
java.net.URI localLocation)
throws java.net.UnknownHostException,
java.io.IOException
- Throws:
java.net.UnknownHostException
java.io.IOException
NIOTransport
public NIOTransport(WireFormat wireFormat,
java.net.Socket socket)
throws java.io.IOException
- Throws:
java.io.IOException
initializeStreams
protected void initializeStreams()
throws java.io.IOException
- Overrides:
initializeStreams
in class TcpTransport
- Throws:
java.io.IOException
serviceRead
protected void serviceRead()
doStart
protected void doStart()
throws java.lang.Exception
- Overrides:
doStart
in class TcpTransport
- Throws:
java.lang.Exception
doStop
protected void doStop(ServiceStopper stopper)
throws java.lang.Exception
- Overrides:
doStop
in class TcpTransport
- Throws:
java.lang.Exception
Copyright © 2005-2016. All Rights Reserved.