public class NonBlockingConnection extends Object implements ServerNetworkConnection, ByteBufferSender
Constructor and Description |
---|
NonBlockingConnection(SocketChannel socketChannel,
ProtocolEngine protocolEngine,
Set<TransportEncryption> encryptionSet,
Runnable onTransportEncryptionAction,
NetworkConnectionScheduler scheduler,
AmqpPort port) |
public NonBlockingConnection(SocketChannel socketChannel, ProtocolEngine protocolEngine, Set<TransportEncryption> encryptionSet, Runnable onTransportEncryptionAction, NetworkConnectionScheduler scheduler, AmqpPort port)
public boolean isPartialRead()
public void start()
start
in interface NetworkConnection
public ByteBufferSender getSender()
getSender
in interface NetworkConnection
public void close()
close
in interface ByteBufferSender
close
in interface NetworkConnection
public SocketAddress getRemoteAddress()
getRemoteAddress
in interface NetworkConnection
public SocketAddress getLocalAddress()
getLocalAddress
in interface NetworkConnection
public void setMaxWriteIdleMillis(long millis)
setMaxWriteIdleMillis
in interface NetworkConnection
public void setMaxReadIdleMillis(long millis)
setMaxReadIdleMillis
in interface NetworkConnection
public Principal getPeerPrincipal()
getPeerPrincipal
in interface NetworkConnection
public Certificate getPeerCertificate()
getPeerCertificate
in interface NetworkConnection
public long getMaxReadIdleMillis()
getMaxReadIdleMillis
in interface NetworkConnection
public long getMaxWriteIdleMillis()
getMaxWriteIdleMillis
in interface NetworkConnection
public void reserveOutboundMessageSpace(long size)
reserveOutboundMessageSpace
in interface ServerNetworkConnection
public String getTransportInfo()
getTransportInfo
in interface ServerNetworkConnection
public boolean isStateChanged()
public void doPreWork()
public boolean doWork()
public void addSchedulingDelayNotificationListeners(SchedulingDelayNotificationListener listener)
addSchedulingDelayNotificationListeners
in interface ServerNetworkConnection
public void removeSchedulingDelayNotificationListeners(SchedulingDelayNotificationListener listener)
removeSchedulingDelayNotificationListeners
in interface ServerNetworkConnection
protected int readFromNetwork() throws IOException
IOException
public void send(QpidByteBuffer msg)
send
in interface ByteBufferSender
public void flush()
flush
in interface ByteBufferSender
public final void pushScheduler(NetworkConnectionScheduler scheduler)
public final NetworkConnectionScheduler popScheduler()
public final NetworkConnectionScheduler getScheduler()
public void processAmqpData(QpidByteBuffer applicationData)
public void setTransportEncryption(TransportEncryption transportEncryption)
public boolean setScheduled()
public void clearScheduled()
public long getScheduledTime()
getScheduledTime
in interface ServerNetworkConnection
public org.apache.qpid.server.transport.SelectorThread.SelectionTask getSelectionTask()
public void setSelectionTask(org.apache.qpid.server.transport.SelectorThread.SelectionTask selectionTask)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.