com.caucho.amqp.common
Class AmqpSenderLink

java.lang.Object
  extended by com.caucho.amqp.common.AmqpLink
      extended by com.caucho.amqp.common.AmqpSenderLink
Direct Known Subclasses:
AmqpClientSenderLink, AmqpServerSenderLink

public abstract class AmqpSenderLink
extends AmqpLink

link management


Constructor Summary
protected AmqpSenderLink(java.lang.String name, java.lang.String address)
           
 
Method Summary
 long getDeliveryCount()
           
 int getLinkCredit()
           
 FrameAttach.Role getRole()
           
 void onFlow(FrameFlow flow)
          When peer sends its link credit, update deliveryLimit.
 void transfer(long mid, SettleMode settleMode, java.io.InputStream is)
           
 
Methods inherited from class com.caucho.amqp.common.AmqpLink
accepted, afterAttach, getAddress, getAttachProperties, getIncomingHandle, getName, getOutgoingHandle, getSession, getSourceProperties, getTargetProperties, modified, onAccepted, onModified, onRejected, onReleased, onTransfer, rejected, released, setIncomingHandle, setOutgoingHandle, setPeerDeliveryCount, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AmqpSenderLink

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

getRole

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

getDeliveryCount

public final long getDeliveryCount()
Overrides:
getDeliveryCount in class AmqpLink
Returns:

getLinkCredit

public final int getLinkCredit()

transfer

public void transfer(long mid,
                     SettleMode settleMode,
                     java.io.InputStream is)

onFlow

public void onFlow(FrameFlow flow)
When peer sends its link credit, update deliveryLimit.

Overrides:
onFlow in class AmqpLink