org.apache.qpid.amqp_1_0.transport

Class ReceivingLinkEndpoint

java.lang.Object

org.apache.qpid.amqp_1_0.transport.LinkEndpoint<ReceivingLinkListener>

org.apache.qpid.amqp_1_0.transport.ReceivingLinkEndpoint

public class ReceivingLinkEndpoint
extends LinkEndpoint<ReceivingLinkListener>

Constructor Summary

Constructors

Constructor and Description
ReceivingLinkEndpoint(SessionEndpoint session, Attach attach)
ReceivingLinkEndpoint(SessionEndpoint session, String name)
ReceivingLinkEndpoint(SessionEndpoint session, String name, Map<Binary,Outcome> unsettledMap)

Method Summary

Modifier and Type	Method and Description
void	clearDrain()
void	drain()
void	flowStateChanged()
UnsignedInteger	getDrainLimit()
Role	getRole()
boolean	isDrained()
void	receiveDeliveryState(Delivery unsettled, DeliveryState state, Boolean settled)
void	receiveFlow(Flow flow)
void	receiveTransfer(Transfer transfer, Delivery delivery)
void	requestTransactionalSend(Object txnId)
void	setCreditWindow()
void	setCreditWindow(boolean window)
void	settle(Binary deliveryTag)
boolean	settled(Binary deliveryTag)
void	settledByPeer(Binary deliveryTag)
void	updateAllDisposition(Binary deliveryTag, DeliveryState deliveryState, boolean settled)
void	updateDisposition(Binary deliveryTag, DeliveryState state, boolean settled)

Methods inherited from class org.apache.qpid.amqp_1_0.transport.LinkEndpoint

addUnsettled, attach, close, close, detach, detach, getAvailable, getDeliveryCount, getDeliveryStateHandler, getDrain, getInitialUnsettledMap, getLinkCredit, getLinkEventListener, getLocalHandle, getLock, getName, getReceivingSettlementMode, getSendingSettlementMode, getSession, getSource, getSyncTimeout, getTarget, getUnsettledCount, isAttached, isDetached, receiveAttach, remoteDetached, sendFlow, sendFlow, sendFlow, sendFlowConditional, sendFlowWithEcho, setAvailable, setDeliveryCount, setDeliveryStateHandler, setDrain, setLinkCredit, setLinkEventListener, setLocalHandle, setLocalUnsettled, setReceivingSettlementMode, setSendingSettlementMode, setSource, setTarget, setTransactionId, toString, waitUntil, waitUntil

Methods inherited from class java.lang.Object

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

Constructor Detail

ReceivingLinkEndpoint

public ReceivingLinkEndpoint(SessionEndpoint session,
                             String name)

ReceivingLinkEndpoint

public ReceivingLinkEndpoint(SessionEndpoint session,
                             String name,
                             Map<Binary,Outcome> unsettledMap)

ReceivingLinkEndpoint

public ReceivingLinkEndpoint(SessionEndpoint session,
                             Attach attach)

Method Detail

getRole

public Role getRole()

Specified by:

getRole in class LinkEndpoint<ReceivingLinkListener>

receiveTransfer

public void receiveTransfer(Transfer transfer,
                            Delivery delivery)

Overrides:

receiveTransfer in class LinkEndpoint<ReceivingLinkListener>

receiveFlow

public void receiveFlow(Flow flow)

Overrides:

receiveFlow in class LinkEndpoint<ReceivingLinkListener>

isDrained

public boolean isDrained()

settledByPeer

public void settledByPeer(Binary deliveryTag)

Overrides:

settledByPeer in class LinkEndpoint<ReceivingLinkListener>

settled

public boolean settled(Binary deliveryTag)

updateDisposition

public void updateDisposition(Binary deliveryTag,
                              DeliveryState state,
                              boolean settled)

setCreditWindow

public void setCreditWindow()

setCreditWindow

public void setCreditWindow(boolean window)

drain

public void drain()

receiveDeliveryState

public void receiveDeliveryState(Delivery unsettled,
                                 DeliveryState state,
                                 Boolean settled)

Overrides:

receiveDeliveryState in class LinkEndpoint<ReceivingLinkListener>

requestTransactionalSend

public void requestTransactionalSend(Object txnId)

clearDrain

public void clearDrain()

updateAllDisposition

public void updateAllDisposition(Binary deliveryTag,
                                 DeliveryState deliveryState,
                                 boolean settled)

settle

public void settle(Binary deliveryTag)

Overrides:

settle in class LinkEndpoint<ReceivingLinkListener>

flowStateChanged

public void flowStateChanged()

Specified by:

flowStateChanged in class LinkEndpoint<ReceivingLinkListener>

getDrainLimit

public UnsignedInteger getDrainLimit()