public class NIOTransport extends TcpTransport
Transport
interface using raw tcp/ipbuffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
NIOTransport(WireFormat wireFormat,
java.net.Socket socket) |
NIOTransport(WireFormat wireFormat,
javax.net.SocketFactory socketFactory,
java.net.URI remoteLocation,
java.net.URI localLocation) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
protected void |
initializeStreams() |
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
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, 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 NIOTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation) throws java.net.UnknownHostException, java.io.IOException
java.net.UnknownHostException
java.io.IOException
public NIOTransport(WireFormat wireFormat, java.net.Socket socket) throws java.io.IOException
java.io.IOException
protected void initializeStreams() throws java.io.IOException
initializeStreams
in class TcpTransport
java.io.IOException
protected void doStart() throws java.lang.Exception
doStart
in class TcpTransport
java.lang.Exception
protected void doStop(ServiceStopper stopper) throws java.lang.Exception
doStop
in class TcpTransport
java.lang.Exception
Copyright © 2005-2012. All Rights Reserved.