com.caucho.amqp.server
Class AmqpServerSenderLink
java.lang.Object
com.caucho.amqp.common.AmqpLink
com.caucho.amqp.common.AmqpSenderLink
com.caucho.amqp.server.AmqpServerSenderLink
public class AmqpServerSenderLink
- extends AmqpSenderLink
link session management
Methods inherited from class com.caucho.amqp.common.AmqpLink |
accepted, afterAttach, getAddress, getAttachProperties, getIncomingHandle, getName, getOutgoingHandle, getSession, getSourceProperties, getTargetProperties, modified, onTransfer, rejected, released, setIncomingHandle, setOutgoingHandle, setPeerDeliveryCount, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
AmqpServerSenderLink
public AmqpServerSenderLink(java.lang.String name,
java.lang.String address,
SettleMode settleMode)
onAccepted
public void onAccepted(long xid,
long mid)
- Overrides:
onAccepted
in class AmqpLink
onReleased
public void onReleased(long xid,
long messageId)
- Overrides:
onReleased
in class AmqpLink
onRejected
public void onRejected(long xid,
long messageId,
AmqpError error)
- Overrides:
onRejected
in class AmqpLink
onModified
public void onModified(long xid,
long mid,
boolean isFailed,
boolean isUndeliverableHere)
- Overrides:
onModified
in class AmqpLink
onFlow
public void onFlow(FrameFlow flow)
- Description copied from class:
AmqpSenderLink
- When peer sends its link credit, update deliveryLimit.
- Overrides:
onFlow
in class AmqpSenderLink
- Parameters:
flow
-