com.caucho.amqp.server

Class AmqpServerReceiverLink

java.lang.Object

com.caucho.amqp.common.AmqpLink

com.caucho.amqp.common.AmqpReceiverLink

com.caucho.amqp.server.AmqpServerReceiverLink

public class AmqpServerReceiverLink
extends AmqpReceiverLink

link session management

Constructor Summary

Constructors

Constructor and Description
AmqpServerReceiverLink(java.lang.String name, java.lang.String address, BrokerSender sender)

Method Summary

Modifier and Type	Method and Description
protected int	getPrefetchAvailable()
protected void	onTransfer(FrameTransfer transfer, AmqpReader ain) receives a message from the network

Methods inherited from class com.caucho.amqp.common.AmqpReceiverLink

accepted, afterAttach, getRole, modified, rejected, released, setPeerDeliveryCount, setPrefetch, updatePrefetch, updateTake, updateTransfer

Methods inherited from class com.caucho.amqp.common.AmqpLink

getAddress, getAttachProperties, getDeliveryCount, getIncomingHandle, getName, getOutgoingHandle, getSession, getSourceProperties, getTargetProperties, onAccepted, onFlow, onModified, onRejected, onReleased, setIncomingHandle, setOutgoingHandle, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpServerReceiverLink

public AmqpServerReceiverLink(java.lang.String name,
                              java.lang.String address,
                              BrokerSender sender)

Method Detail

onTransfer

protected void onTransfer(FrameTransfer transfer,
                          AmqpReader ain)
                   throws java.io.IOException

receives a message from the network

Overrides:

onTransfer in class AmqpReceiverLink

Throws:

java.io.IOException

getPrefetchAvailable

protected int getPrefetchAvailable()

Overrides:

getPrefetchAvailable in class AmqpReceiverLink