org.apache.activemq.transport.nio
Class NIOTransport

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.transport.TransportSupport
          extended by org.apache.activemq.transport.TransportThreadSupport
              extended by org.apache.activemq.transport.tcp.TcpTransport
                  extended by 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


Field Summary
protected  java.nio.channels.SocketChannel channel
           
protected  java.nio.ByteBuffer currentBuffer
           
protected  java.nio.ByteBuffer inputBuffer
           
protected  int nextFrameSize
           
protected  SelectorSelection selection
           
 
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
 
Constructor Summary
NIOTransport(WireFormat wireFormat, java.net.Socket socket)
           
NIOTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
protected  void initializeStreams()
           
protected  void serviceRead()
           
 
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.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, 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
 
Methods inherited from interface org.apache.activemq.Service
start
 

Field Detail

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
Constructor Detail

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
Method Detail

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-2015. All Rights Reserved.