public abstract class LinkEndpoint<T extends LinkEventListener> extends Object
public String getName()
public abstract Role getRole()
public Source getSource()
public void setSource(Source source)
public Target getTarget()
public void setTarget(Target target)
public void setDeliveryCount(UnsignedInteger deliveryCount)
public void setLinkCredit(UnsignedInteger linkCredit)
public void setAvailable(UnsignedInteger available)
public void setDrain(Boolean drain)
public UnsignedInteger getDeliveryCount()
public UnsignedInteger getAvailable()
public Boolean getDrain()
public UnsignedInteger getLinkCredit()
public void remoteDetached(Detach detach)
public void settledByPeer(Binary deliveryTag)
public void receiveFlow(Flow flow)
public void addUnsettled(Delivery unsettled)
public void receiveDeliveryState(Delivery unsettled, DeliveryState state, Boolean settled)
public void settle(Binary deliveryTag)
public int getUnsettledCount()
public void setLocalHandle(UnsignedInteger localHandle)
public void receiveAttach(Attach attach)
public boolean isAttached()
public boolean isDetached()
public SessionEndpoint getSession()
public UnsignedInteger getLocalHandle()
public Object getLock()
public long getSyncTimeout()
public void waitUntil(Predicate predicate) throws TimeoutException, InterruptedException
TimeoutException
InterruptedException
public void waitUntil(Predicate predicate, long timeout) throws TimeoutException, InterruptedException
TimeoutException
InterruptedException
public void attach()
public void detach()
public void close()
public void close(Error error)
public void detach(Error error)
public void setTransactionId(Object txnId)
public void sendFlowConditional()
public void sendFlow()
public void sendFlowWithEcho()
public void sendFlow(boolean setTransactionId)
public void sendFlow(boolean setTransactionId, boolean echo)
public T getLinkEventListener()
public void setLinkEventListener(T linkEventListener)
public DeliveryStateHandler getDeliveryStateHandler()
public void setDeliveryStateHandler(DeliveryStateHandler deliveryStateHandler)
public void setSendingSettlementMode(SenderSettleMode sendingSettlementMode)
public SenderSettleMode getSendingSettlementMode()
public ReceiverSettleMode getReceivingSettlementMode()
public void setReceivingSettlementMode(ReceiverSettleMode receivingSettlementMode)
public Map getInitialUnsettledMap()
public abstract void flowStateChanged()
public void setLocalUnsettled(Map unsettled)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.