public class NIOTransport extends TcpTransport
Transport
interface using raw tcp/ipModifier and Type | Field and Description |
---|---|
protected SocketChannel |
channel |
protected ByteBuffer |
currentBuffer |
protected ByteBuffer |
inputBuffer |
protected int |
nextFrameSize |
protected SelectorSelection |
selection |
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
NIOTransport(WireFormat wireFormat,
Socket socket) |
NIOTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
protected void |
initializeStreams() |
protected void |
serviceRead() |
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
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
protected SocketChannel channel
protected SelectorSelection selection
protected ByteBuffer inputBuffer
protected ByteBuffer currentBuffer
protected int nextFrameSize
public NIOTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostException
IOException
public NIOTransport(WireFormat wireFormat, Socket socket) throws IOException
IOException
protected void initializeStreams() throws IOException
initializeStreams
in class TcpTransport
IOException
protected void serviceRead()
protected void doStart() throws Exception
doStart
in class TcpTransport
Exception
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class TcpTransport
Exception
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.