public class SessionEndpoint extends Object
Constructor and Description |
---|
SessionEndpoint(ConnectionEndpoint connectionEndpoint) |
SessionEndpoint(ConnectionEndpoint connectionEndpoint,
Begin begin) |
SessionEndpoint(ConnectionEndpoint connectionEndpoint,
UnsignedInteger nextOutgoingId) |
public SessionEndpoint(ConnectionEndpoint connectionEndpoint)
public SessionEndpoint(ConnectionEndpoint connectionEndpoint, Begin begin)
public SessionEndpoint(ConnectionEndpoint connectionEndpoint, UnsignedInteger nextOutgoingId)
public void setReceivingChannel(short receivingChannel)
public void setSendingChannel(short sendingChannel)
public SessionState getState()
public void end()
public void end(End end)
public void receiveEnd(End end)
public boolean isSyntheticError(Error error)
public short getSendingChannel()
public void receiveAttach(Attach attach)
public void receiveDetach(Detach detach)
public void receiveTransfer(Transfer transfer)
public void receiveFlow(Flow flow)
public void receiveDisposition(Disposition disposition)
public SendingLinkEndpoint createSendingLinkEndpoint(String name, String targetAddr, String sourceAddr)
public SendingLinkEndpoint createSendingLinkEndpoint(String name, String targetAddr, String sourceAddr, Map<Binary,Outcome> unsettled)
public SendingLinkEndpoint createSendingLinkEndpoint(String name, String targetAddr, String sourceAddr, boolean durable, Map<Binary,Outcome> unsettled)
public SendingLinkEndpoint createSendingLinkEndpoint(String name, Source source, Target target)
public SendingLinkEndpoint createSendingLinkEndpoint(String name, Source source, Target target, Map<Binary,Outcome> unsettled)
public SendingLinkEndpoint createSendingLinkEndpoint(String name, Source source, Target target, Map<Binary,Outcome> unsettled, DeliveryStateHandler deliveryStateHandler)
public void sendAttach(Attach attach)
public void sendTransfer(Transfer xfr, SendingLinkEndpoint endpoint, boolean newDelivery)
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 ReceivingLinkEndpoint createReceivingLinkEndpoint(String name, String targetAddr, String sourceAddr, UnsignedInteger initialCredit, DistributionMode distributionMode)
public ReceivingLinkEndpoint createReceivingLinkEndpoint(String name, Target target, Source source, UnsignedInteger initialCredit)
public void updateDisposition(Role role, UnsignedInteger first, UnsignedInteger last, DeliveryState state, boolean settled)
public void settle(Role role, UnsignedInteger deliveryId)
public void sendFlow()
public void sendFlow(Flow flow)
public void sendFlowConditional()
public void sendDetach(Detach detach)
public void setNextIncomingId(UnsignedInteger nextIncomingId)
public void setOutgoingSessionCredit(UnsignedInteger outgoingSessionCredit)
public UnsignedInteger getNextOutgoingId()
public UnsignedInteger getOutgoingWindowSize()
public boolean hasCreditToSend()
public UnsignedInteger getIncomingWindowSize()
public SessionEventListener getSessionEventListener()
public void setSessionEventListener(SessionEventListener sessionEventListener)
public ConnectionEndpoint getConnection()
public SendingLinkEndpoint createTransactionController(String name, TxnCapability... capabilities)
public Collection<LinkEndpoint> getLocalLinkEndpoints()
public boolean isEnded()
public boolean isActive()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.