com.caucho.amqp.common

Class AmqpReceiverLink

java.lang.Object

com.caucho.amqp.common.AmqpLink

com.caucho.amqp.common.AmqpReceiverLink

Direct Known Subclasses:

AmqpClientReceiverLink, AmqpServerReceiverLink

public abstract class AmqpReceiverLink
extends AmqpLink

link management

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	accepted(long mid)
void	afterAttach() Called after the attach has been sent to the peer.
protected int	getPrefetchAvailable()
FrameAttach.Role	getRole()
void	modified(long mid, boolean isFailure, boolean isUndeliverableHere)
protected void	onTransfer(FrameTransfer transfer, AmqpReader ain) Message receivers implement this method to receive a message fragment from the network.
void	rejected(long mid, java.lang.String message)
void	released(long mid)
void	setPeerDeliveryCount(long deliveryCount)
void	setPrefetch(int prefetch)
void	updatePrefetch(int prefetch)
void	updateTake()
protected void	updateTransfer()

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

getAddress, getAttachProperties, getDeliveryCount, getIncomingHandle, getName, getOutgoingHandle, getSession, getSourceProperties, getTargetProperties, onAccepted, onFlow, onModified, onRejected, onReleased, setIncomingHandle, setOutgoingHandle, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AmqpReceiverLink

protected AmqpReceiverLink(java.lang.String name,
                           java.lang.String address)

Method Detail

getRole

public final FrameAttach.Role getRole()

Specified by:

getRole in class AmqpLink

afterAttach

public void afterAttach()

Called after the attach has been sent to the peer.

Overrides:

afterAttach in class AmqpLink

getPrefetchAvailable

protected int getPrefetchAvailable()

onTransfer

protected void onTransfer(FrameTransfer transfer,
                          AmqpReader ain)
                   throws java.io.IOException

Message receivers implement this method to receive a message fragment from the network.

Overrides:

onTransfer in class AmqpLink

Throws:

java.io.IOException

updateTransfer

protected final void updateTransfer()

accepted

public void accepted(long mid)

Overrides:

accepted in class AmqpLink

rejected

public void rejected(long mid,
                     java.lang.String message)

Overrides:

rejected in class AmqpLink

released

public void released(long mid)

Overrides:

released in class AmqpLink

modified

public void modified(long mid,
                     boolean isFailure,
                     boolean isUndeliverableHere)

Overrides:

modified in class AmqpLink

updateTake

public void updateTake()

setPeerDeliveryCount

public void setPeerDeliveryCount(long deliveryCount)

Overrides:

setPeerDeliveryCount in class AmqpLink

setPrefetch

public final void setPrefetch(int prefetch)

updatePrefetch

public void updatePrefetch(int prefetch)