com.caucho.amqp.common
Class AmqpSenderLink
java.lang.Object
com.caucho.amqp.common.AmqpLink
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)
|
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 |
AmqpSenderLink
protected AmqpSenderLink(java.lang.String name,
java.lang.String address)
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