com.caucho.amqp.common
Class AmqpReceiverLink

java.lang.Object
  extended by com.caucho.amqp.common.AmqpLink
      extended by com.caucho.amqp.common.AmqpReceiverLink
Direct Known Subclasses:
AmqpClientReceiverLink, AmqpServerReceiverLink

public abstract class AmqpReceiverLink
extends AmqpLink

link management


Constructor Summary
protected AmqpReceiverLink(java.lang.String name, java.lang.String address)
           
 
Method Summary
 void accepted(long mid)
           
 void afterAttach()
          Called after the attach has been sent to the peer.
protected  int getPrefetchAvailable()
           
 FrameAttach.Role getRole()
           
 void modified(long mid, boolean isFailure, boolean isUndeliverableHere)
           
protected  void onTransfer(FrameTransfer transfer, AmqpReader ain)
          Message receivers implement this method to receive a message fragment from the network.
 void rejected(long mid, java.lang.String message)
           
 void released(long mid)
           
 void setPeerDeliveryCount(long deliveryCount)
           
 void setPrefetch(int prefetch)
           
 void updatePrefetch(int prefetch)
           
 void updateTake()
           
protected  void 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

AmqpReceiverLink

protected AmqpReceiverLink(java.lang.String name,
                           java.lang.String address)
Method Detail

getRole

public final FrameAttach.Role getRole()
Specified by:
getRole in class AmqpLink

afterAttach

public void afterAttach()
Called after the attach has been sent to the peer.

Overrides:
afterAttach in class AmqpLink

getPrefetchAvailable

protected int getPrefetchAvailable()

onTransfer

protected void onTransfer(FrameTransfer transfer,
                          AmqpReader ain)
                   throws java.io.IOException
Message receivers implement this method to receive a message fragment from the network.

Overrides:
onTransfer in class AmqpLink
Throws:
java.io.IOException

updateTransfer

protected final void updateTransfer()

accepted

public void accepted(long mid)
Overrides:
accepted in class AmqpLink

rejected

public void rejected(long mid,
                     java.lang.String message)
Overrides:
rejected in class AmqpLink

released

public void released(long mid)
Overrides:
released in class AmqpLink

modified

public void modified(long mid,
                     boolean isFailure,
                     boolean isUndeliverableHere)
Overrides:
modified in class AmqpLink

updateTake

public void updateTake()

setPeerDeliveryCount

public void setPeerDeliveryCount(long deliveryCount)
Overrides:
setPeerDeliveryCount in class AmqpLink

setPrefetch

public final void setPrefetch(int prefetch)

updatePrefetch

public void updatePrefetch(int prefetch)