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

Constructors

Modifier	Constructor and Description
protected	AmqpSenderLink(java.lang.String name, java.lang.String address)

Method Summary

Modifier and Type	Method and Description
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