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
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, getSoTimeout, getTcpNoDelay, getTypeOfService, initialiseSocket, isCloseAsync, isDynamicManagement, isStartLogging, isTrace, isUseLocalHost, narrow, oneway, readCommand, resolveHostName, run, setCloseAsync, setConnectionTimeout, setDiffServ, setDynamicManagement, setIoBufferSize, setJmxPort, setKeepAlive, setLogWriterName, setMinmumWireFormatVersion, setSocketBufferSize, setSocketOptions, 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 |
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
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-2011. All Rights Reserved.