org.apache.qpid.server.transport

Class NonBlockingConnection

java.lang.Object

org.apache.qpid.server.transport.NonBlockingConnection

All Implemented Interfaces:

ServerNetworkConnection, ByteBufferSender, NetworkConnection

public class NonBlockingConnection
extends Object
implements ServerNetworkConnection, ByteBufferSender

Constructor Summary

Constructors

Constructor and Description
NonBlockingConnection(SocketChannel socketChannel, ProtocolEngine protocolEngine, Set<TransportEncryption> encryptionSet, Runnable onTransportEncryptionAction, NetworkConnectionScheduler scheduler, AmqpPort port)

Method Summary

Modifier and Type	Method and Description
void	addSchedulingDelayNotificationListeners(SchedulingDelayNotificationListener listener)
void	clearScheduled()
void	close()
void	doPreWork()
boolean	doWork()
void	flush()
SocketAddress	getLocalAddress()
long	getMaxReadIdleMillis()
long	getMaxWriteIdleMillis()
Certificate	getPeerCertificate()
Principal	getPeerPrincipal()
SocketAddress	getRemoteAddress()
long	getScheduledTime()
NetworkConnectionScheduler	getScheduler()
org.apache.qpid.server.transport.SelectorThread.SelectionTask	getSelectionTask()
ByteBufferSender	getSender()
String	getTransportInfo()
boolean	isPartialRead()
boolean	isStateChanged()
NetworkConnectionScheduler	popScheduler()
void	processAmqpData(QpidByteBuffer applicationData)
void	pushScheduler(NetworkConnectionScheduler scheduler)
protected int	readFromNetwork()
void	removeSchedulingDelayNotificationListeners(SchedulingDelayNotificationListener listener)
void	reserveOutboundMessageSpace(long size)
void	send(QpidByteBuffer msg)
void	setMaxReadIdleMillis(long millis)
void	setMaxWriteIdleMillis(long millis)
boolean	setScheduled()
void	setSelectionTask(org.apache.qpid.server.transport.SelectorThread.SelectionTask selectionTask)
void	setTransportEncryption(TransportEncryption transportEncryption)
void	start()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NonBlockingConnection

public NonBlockingConnection(SocketChannel socketChannel,
                             ProtocolEngine protocolEngine,
                             Set<TransportEncryption> encryptionSet,
                             Runnable onTransportEncryptionAction,
                             NetworkConnectionScheduler scheduler,
                             AmqpPort port)

Method Detail

isPartialRead

public boolean isPartialRead()

start

public void start()

Specified by:

start in interface NetworkConnection

getSender

public ByteBufferSender getSender()

Specified by:

getSender in interface NetworkConnection

close

public void close()

Specified by:

close in interface ByteBufferSender

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.

setMaxWriteIdleMillis

public void setMaxWriteIdleMillis(long millis)

Specified by:

setMaxWriteIdleMillis in interface NetworkConnection

setMaxReadIdleMillis

public void setMaxReadIdleMillis(long millis)

Specified by:

setMaxReadIdleMillis in interface NetworkConnection

getPeerPrincipal

public Principal getPeerPrincipal()

Specified by:

getPeerPrincipal in interface NetworkConnection

getPeerCertificate

public Certificate getPeerCertificate()

Specified by:

getPeerCertificate in interface NetworkConnection

getMaxReadIdleMillis

public long getMaxReadIdleMillis()

Specified by:

getMaxReadIdleMillis in interface NetworkConnection

getMaxWriteIdleMillis

public long getMaxWriteIdleMillis()

Specified by:

getMaxWriteIdleMillis in interface NetworkConnection

reserveOutboundMessageSpace

public void reserveOutboundMessageSpace(long size)

Specified by:

reserveOutboundMessageSpace in interface ServerNetworkConnection

getTransportInfo

public String getTransportInfo()

Specified by:

getTransportInfo in interface ServerNetworkConnection

isStateChanged

public boolean isStateChanged()

doPreWork

public void doPreWork()

doWork

public boolean doWork()

addSchedulingDelayNotificationListeners

public void addSchedulingDelayNotificationListeners(SchedulingDelayNotificationListener listener)

Specified by:

addSchedulingDelayNotificationListeners in interface ServerNetworkConnection

removeSchedulingDelayNotificationListeners

public void removeSchedulingDelayNotificationListeners(SchedulingDelayNotificationListener listener)

Specified by:

removeSchedulingDelayNotificationListeners in interface ServerNetworkConnection

readFromNetwork

protected int readFromNetwork()
                       throws IOException

Throws:

IOException

send

public void send(QpidByteBuffer msg)

Specified by:

send in interface ByteBufferSender

flush

public void flush()

Specified by:

flush in interface ByteBufferSender

pushScheduler

public final void pushScheduler(NetworkConnectionScheduler scheduler)

popScheduler

public final NetworkConnectionScheduler popScheduler()

getScheduler

public final NetworkConnectionScheduler getScheduler()

toString

public String toString()

Overrides:

toString in class Object

processAmqpData

public void processAmqpData(QpidByteBuffer applicationData)

setTransportEncryption

public void setTransportEncryption(TransportEncryption transportEncryption)

setScheduled

public boolean setScheduled()

clearScheduled

public void clearScheduled()

getScheduledTime

public long getScheduledTime()

Specified by:

getScheduledTime in interface ServerNetworkConnection

getSelectionTask

public org.apache.qpid.server.transport.SelectorThread.SelectionTask getSelectionTask()

setSelectionTask

public void setSelectionTask(org.apache.qpid.server.transport.SelectorThread.SelectionTask selectionTask)