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

Constructor Summary

Constructors

Constructor and Description
AmqpServerSenderLink(java.lang.String name, java.lang.String address, SettleMode settleMode)

Method Summary

Modifier and Type	Method and Description
void	onAccepted(long xid, long mid)
void	onFlow(FrameFlow flow) When peer sends its link credit, update deliveryLimit.
void	onModified(long xid, long mid, boolean isFailed, boolean isUndeliverableHere)
void	onRejected(long xid, long messageId, AmqpError error)
void	onReleased(long xid, long messageId)

Methods inherited from class com.caucho.amqp.common.AmqpSenderLink

getDeliveryCount, getLinkCredit, getRole, transfer

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

Constructor Detail

AmqpServerSenderLink

public AmqpServerSenderLink(java.lang.String name,
                            java.lang.String address,
                            SettleMode settleMode)

Method Detail

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 -