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 |
protected |
AmqpReceiverLink(java.lang.String name,
java.lang.String address)
|
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 |
AmqpReceiverLink
protected AmqpReceiverLink(java.lang.String name,
java.lang.String address)
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)