public class ReceivingLinkEndpoint extends LinkEndpoint<ReceivingLinkListener>
Constructor and Description |
---|
ReceivingLinkEndpoint(SessionEndpoint session,
Attach attach) |
ReceivingLinkEndpoint(SessionEndpoint session,
String name) |
ReceivingLinkEndpoint(SessionEndpoint session,
String name,
Map<Binary,Outcome> unsettledMap) |
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) |
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
public ReceivingLinkEndpoint(SessionEndpoint session, String name)
public ReceivingLinkEndpoint(SessionEndpoint session, String name, Map<Binary,Outcome> unsettledMap)
public ReceivingLinkEndpoint(SessionEndpoint session, Attach attach)
public Role getRole()
getRole
in class LinkEndpoint<ReceivingLinkListener>
public void receiveTransfer(Transfer transfer, Delivery delivery)
receiveTransfer
in class LinkEndpoint<ReceivingLinkListener>
public void receiveFlow(Flow flow)
receiveFlow
in class LinkEndpoint<ReceivingLinkListener>
public boolean isDrained()
public void settledByPeer(Binary deliveryTag)
settledByPeer
in class LinkEndpoint<ReceivingLinkListener>
public boolean settled(Binary deliveryTag)
public void updateDisposition(Binary deliveryTag, DeliveryState state, boolean settled)
public void setCreditWindow()
public void setCreditWindow(boolean window)
public void drain()
public void receiveDeliveryState(Delivery unsettled, DeliveryState state, Boolean settled)
receiveDeliveryState
in class LinkEndpoint<ReceivingLinkListener>
public void requestTransactionalSend(Object txnId)
public void clearDrain()
public void updateAllDisposition(Binary deliveryTag, DeliveryState deliveryState, boolean settled)
public void settle(Binary deliveryTag)
settle
in class LinkEndpoint<ReceivingLinkListener>
public void flowStateChanged()
flowStateChanged
in class LinkEndpoint<ReceivingLinkListener>
public UnsignedInteger getDrainLimit()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.