public class AutoNIOTransport extends NIOTransport
TcpTransport.InitBuffer
channel, currentBuffer, inputBuffer, nextFrameSize, selection
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, initBuffer, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
AutoNIOTransport(WireFormat wireFormat,
Socket socket) |
AutoNIOTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
AutoNIOTransport(WireFormat format,
Socket socket,
TcpTransport.InitBuffer initBuffer) |
Modifier and Type | Method and Description |
---|---|
protected int |
readFromBuffer()
Read from the initial buffer if it is set
|
doStart, doStop, initializeStreams, serviceRead
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
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
public AutoNIOTransport(WireFormat format, Socket socket, TcpTransport.InitBuffer initBuffer) throws IOException
IOException
public AutoNIOTransport(WireFormat wireFormat, Socket socket) throws IOException
IOException
public AutoNIOTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostException
IOException
protected int readFromBuffer() throws IOException
readFromBuffer
in class NIOTransport
IOException
Copyright © 2005–2018. All rights reserved.