com.caucho.amqp.server
Class AmqpServerReceiverLink

java.lang.Object
  extended by com.caucho.amqp.common.AmqpLink
      extended by com.caucho.amqp.common.AmqpReceiverLink
          extended by com.caucho.amqp.server.AmqpServerReceiverLink

public class AmqpServerReceiverLink
extends AmqpReceiverLink

link session management


Constructor Summary
AmqpServerReceiverLink(java.lang.String name, java.lang.String address, BrokerSender sender)
           
 
Method Summary
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