org.apache.qpid.transport.network.io

Class IoNetworkConnection

java.lang.Object

org.apache.qpid.transport.network.io.IoNetworkConnection

All Implemented Interfaces:

NetworkConnection

public class IoNetworkConnection
extends Object
implements NetworkConnection

Constructor Summary

Constructors

Constructor and Description
IoNetworkConnection(Socket socket, Receiver<ByteBuffer> delegate, int sendBufferSize, int receiveBufferSize, long timeout, Ticker ticker)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
SocketAddress	getLocalAddress()
int	getMaxReadIdle()
int	getMaxWriteIdle()
Principal	getPeerPrincipal()
SocketAddress	getRemoteAddress()
Sender<ByteBuffer>	getSender()
void	setMaxReadIdle(int sec)
void	setMaxWriteIdle(int sec)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IoNetworkConnection

public IoNetworkConnection(Socket socket,
                   Receiver<ByteBuffer> delegate,
                   int sendBufferSize,
                   int receiveBufferSize,
                   long timeout,
                   Ticker ticker)

Method Detail

start

public void start()

Specified by:

start in interface NetworkConnection

getSender

public Sender<ByteBuffer> getSender()

Specified by:

getSender in interface NetworkConnection

close

public void close()

Specified by:

close in interface NetworkConnection

getRemoteAddress

public SocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface NetworkConnection

Returns:

the remote address of the underlying socket.

getLocalAddress

public SocketAddress getLocalAddress()

Specified by:

getLocalAddress in interface NetworkConnection

Returns:

the local address of the underlying socket.

setMaxWriteIdle

public void setMaxWriteIdle(int sec)

Specified by:

setMaxWriteIdle in interface NetworkConnection

setMaxReadIdle

public void setMaxReadIdle(int sec)

Specified by:

setMaxReadIdle in interface NetworkConnection

getPeerPrincipal

public Principal getPeerPrincipal()

Specified by:

getPeerPrincipal in interface NetworkConnection

getMaxReadIdle

public int getMaxReadIdle()

Specified by:

getMaxReadIdle in interface NetworkConnection

getMaxWriteIdle

public int getMaxWriteIdle()

Specified by:

getMaxWriteIdle in interface NetworkConnection