LinkImpl

Undocumented in source.
class LinkImpl : EndpointImpl , Link {}

Constructors

this
this(SessionImpl session, string name)
Undocumented in source.

Members

Functions

addCredit
void addCredit(int credit)
Undocumented in source. Be warned that the author may not have intended to support it.
advance
bool advance()
Undocumented in source. Be warned that the author may not have intended to support it.
current
DeliveryImpl current()
Undocumented in source. Be warned that the author may not have intended to support it.
decrementCredit
void decrementCredit()
Undocumented in source. Be warned that the author may not have intended to support it.
decrementQueued
void decrementQueued()
Undocumented in source. Be warned that the author may not have intended to support it.
decrementUnsettled
void decrementUnsettled()
Undocumented in source. Be warned that the author may not have intended to support it.
delivery
DeliveryImpl delivery(byte[] tag)
Undocumented in source. Be warned that the author may not have intended to support it.
delivery
DeliveryImpl delivery(byte[] tag, int offset, int length)
Undocumented in source. Be warned that the author may not have intended to support it.
detach
void detach()
Undocumented in source. Be warned that the author may not have intended to support it.
detached
bool detached()
Undocumented in source. Be warned that the author may not have intended to support it.
doFree
void doFree()
Undocumented in source. Be warned that the author may not have intended to support it.
drained
int drained()
Undocumented in source. Be warned that the author may not have intended to support it.
getConnectionImpl
ConnectionImpl getConnectionImpl()
Undocumented in source. Be warned that the author may not have intended to support it.
getCredit
int getCredit()
Undocumented in source. Be warned that the author may not have intended to support it.
getDesiredCapabilities
Symbol[] getDesiredCapabilities()
Undocumented in source. Be warned that the author may not have intended to support it.
getDrain
bool getDrain()
Undocumented in source. Be warned that the author may not have intended to support it.
getDrained
int getDrained()
Undocumented in source. Be warned that the author may not have intended to support it.
getMaxMessageSize
UnsignedLong getMaxMessageSize()
Undocumented in source. Be warned that the author may not have intended to support it.
getName
string getName()
Undocumented in source. Be warned that the author may not have intended to support it.
getOfferedCapabilities
Symbol[] getOfferedCapabilities()
Undocumented in source. Be warned that the author may not have intended to support it.
getProperties
Map!(Symbol, Object) getProperties()
Undocumented in source. Be warned that the author may not have intended to support it.
getQueued
int getQueued()
Undocumented in source. Be warned that the author may not have intended to support it.
getReceiverSettleMode
ReceiverSettleMode getReceiverSettleMode()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteDesiredCapabilities
Symbol[] getRemoteDesiredCapabilities()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteMaxMessageSize
UnsignedLong getRemoteMaxMessageSize()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteOfferedCapabilities
Symbol[] getRemoteOfferedCapabilities()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteProperties
Map!(Symbol, Object) getRemoteProperties()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteReceiverSettleMode
ReceiverSettleMode getRemoteReceiverSettleMode()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteSenderSettleMode
SenderSettleMode getRemoteSenderSettleMode()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteSource
Source getRemoteSource()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteTarget
Target getRemoteTarget()
Undocumented in source. Be warned that the author may not have intended to support it.
getSenderSettleMode
SenderSettleMode getSenderSettleMode()
Undocumented in source. Be warned that the author may not have intended to support it.
getSession
SessionImpl getSession()
Undocumented in source. Be warned that the author may not have intended to support it.
getSource
Source getSource()
Undocumented in source. Be warned that the author may not have intended to support it.
getTarget
Target getTarget()
Undocumented in source. Be warned that the author may not have intended to support it.
getTransportLink
TransportLink getTransportLink()
Undocumented in source.
getUnsettled
int getUnsettled()
Undocumented in source. Be warned that the author may not have intended to support it.
hasCredit
bool hasCredit()
Undocumented in source. Be warned that the author may not have intended to support it.
head
DeliveryImpl head()
Undocumented in source. Be warned that the author may not have intended to support it.
incrementCredit
void incrementCredit()
Undocumented in source. Be warned that the author may not have intended to support it.
incrementQueued
void incrementQueued()
Undocumented in source. Be warned that the author may not have intended to support it.
incrementUnsettled
void incrementUnsettled()
Undocumented in source. Be warned that the author may not have intended to support it.
localClose
void localClose()
Undocumented in source. Be warned that the author may not have intended to support it.
localOpen
void localOpen()
Undocumented in source. Be warned that the author may not have intended to support it.
modifyEndpoints
void modifyEndpoints()
Undocumented in source. Be warned that the author may not have intended to support it.
next
Link next(Set!EndpointState local, Set!EndpointState remote)
Undocumented in source. Be warned that the author may not have intended to support it.
postFinal
void postFinal()
Undocumented in source. Be warned that the author may not have intended to support it.
remove
void remove(DeliveryImpl delivery)
Undocumented in source. Be warned that the author may not have intended to support it.
setCredit
void setCredit(int credit)
Undocumented in source. Be warned that the author may not have intended to support it.
setDesiredCapabilities
void setDesiredCapabilities(Symbol[] desiredCapabilities)
Undocumented in source. Be warned that the author may not have intended to support it.
setDrain
void setDrain(bool drain)
Undocumented in source. Be warned that the author may not have intended to support it.
setDrained
void setDrained(int value)
Undocumented in source. Be warned that the author may not have intended to support it.
setMaxMessageSize
void setMaxMessageSize(UnsignedLong maxMessageSize)
Undocumented in source. Be warned that the author may not have intended to support it.
setOfferedCapabilities
void setOfferedCapabilities(Symbol[] offeredCapabilities)
Undocumented in source. Be warned that the author may not have intended to support it.
setProperties
void setProperties(Map!(Symbol, Object) properties)
Undocumented in source. Be warned that the author may not have intended to support it.
setReceiverSettleMode
void setReceiverSettleMode(ReceiverSettleMode receiverSettleMode)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteDesiredCapabilities
void setRemoteDesiredCapabilities(Symbol[] remoteDesiredCapabilities)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteMaxMessageSize
void setRemoteMaxMessageSize(UnsignedLong remoteMaxMessageSize)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteOfferedCapabilities
void setRemoteOfferedCapabilities(Symbol[] remoteOfferedCapabilities)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteProperties
void setRemoteProperties(Map!(Symbol, Object) remoteProperties)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteReceiverSettleMode
void setRemoteReceiverSettleMode(ReceiverSettleMode remoteReceiverSettleMode)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteSenderSettleMode
void setRemoteSenderSettleMode(SenderSettleMode remoteSenderSettleMode)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteSource
void setRemoteSource(Source source)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteTarget
void setRemoteTarget(Target target)
Undocumented in source. Be warned that the author may not have intended to support it.
setSenderSettleMode
void setSenderSettleMode(SenderSettleMode senderSettleMode)
Undocumented in source. Be warned that the author may not have intended to support it.
setSource
void setSource(Source source)
Undocumented in source. Be warned that the author may not have intended to support it.
setTarget
void setTarget(Target target)
Undocumented in source. Be warned that the author may not have intended to support it.

Variables

_current
DeliveryImpl _current;
Undocumented in source.
_head
DeliveryImpl _head;
Undocumented in source.
_tail
DeliveryImpl _tail;
Undocumented in source.

Inherited Members

From EndpointImpl

freed
bool freed;
Undocumented in source.
incref
void incref()
Undocumented in source. Be warned that the author may not have intended to support it.
decref
void decref()
Undocumented in source. Be warned that the author may not have intended to support it.
postFinal
void postFinal()
Undocumented in source.
localOpen
void localOpen()
Undocumented in source.
localClose
void localClose()
Undocumented in source.
open
void open()
Undocumented in source. Be warned that the author may not have intended to support it.
close
void close()
Undocumented in source. Be warned that the author may not have intended to support it.
getLocalState
EndpointState getLocalState()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteState
EndpointState getRemoteState()
Undocumented in source. Be warned that the author may not have intended to support it.
getCondition
ErrorCondition getCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
setCondition
void setCondition(ErrorCondition condition)
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteCondition
ErrorCondition getRemoteCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
setLocalState
void setLocalState(EndpointState localState)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteState
void setRemoteState(EndpointState remoteState)
Undocumented in source. Be warned that the author may not have intended to support it.
modified
void modified()
Undocumented in source. Be warned that the author may not have intended to support it.
modified
void modified(bool emit)
Undocumented in source. Be warned that the author may not have intended to support it.
getConnectionImpl
ConnectionImpl getConnectionImpl()
Undocumented in source.
clearModified
void clearModified()
Undocumented in source. Be warned that the author may not have intended to support it.
isModified
bool isModified()
Undocumented in source. Be warned that the author may not have intended to support it.
transportNext
EndpointImpl transportNext()
Undocumented in source. Be warned that the author may not have intended to support it.
transportPrev
EndpointImpl transportPrev()
Undocumented in source. Be warned that the author may not have intended to support it.
doFree
void doFree()
Undocumented in source.
free
void free()
Undocumented in source. Be warned that the author may not have intended to support it.
setTransportNext
void setTransportNext(EndpointImpl transportNext)
Undocumented in source. Be warned that the author may not have intended to support it.
setTransportPrev
void setTransportPrev(EndpointImpl transportPrevious)
Undocumented in source. Be warned that the author may not have intended to support it.
getContext
Object getContext()
Undocumented in source. Be warned that the author may not have intended to support it.
setContext
void setContext(Object context)
Undocumented in source. Be warned that the author may not have intended to support it.
attachments
Record attachments()
Undocumented in source. Be warned that the author may not have intended to support it.
getName
string getName()

Returns the name of the link

delivery
Delivery delivery(byte[] tag)

Create a delivery object based on the specified tag and adds it to the this link's delivery list and its connection work list.

delivery
Delivery delivery(byte[] tag, int offset, int length)

Create a delivery object based on the specified tag. This form of the method is intended to allow the tag to be formed from a subsequence of the byte array passed in. This might allow more optimisation options in future but at present is not implemented.

head
Delivery head()

Returns the head delivery on the link.

current
Delivery current()

Returns the current delivery

advance
bool advance()

Attempts to advance the current delivery. Advances it to the next delivery if one exists, else null.

getSource
Source getSource()
Undocumented in source.
getTarget
Target getTarget()
Undocumented in source.
setSource
void setSource(Source address)

Sets the source for this link.

setTarget
void setTarget(Target address)

Expected to be used in a similar manner to {@link #setSource(Source)}

getRemoteSource
Source getRemoteSource()

@see #setSource(Source)

getRemoteTarget
Target getRemoteTarget()

@see #setTarget(Target)

next
Link next(Set!EndpointState local, Set!EndpointState remote)
Undocumented in source.
getCredit
int getCredit()

Gets the credit balance for a link.

getQueued
int getQueued()

Gets the number of queued messages for a link.

getUnsettled
int getUnsettled()
Undocumented in source.
getSession
Session getSession()
Undocumented in source.
getSenderSettleMode
SenderSettleMode getSenderSettleMode()
Undocumented in source.
setSenderSettleMode
void setSenderSettleMode(SenderSettleMode senderSettleMode)

Sets the sender settle mode.

getRemoteSenderSettleMode
SenderSettleMode getRemoteSenderSettleMode()

@see #setSenderSettleMode(SenderSettleMode)

getReceiverSettleMode
ReceiverSettleMode getReceiverSettleMode()
Undocumented in source.
setReceiverSettleMode
void setReceiverSettleMode(ReceiverSettleMode receiverSettleMode)

Sets the receiver settle mode.

getRemoteReceiverSettleMode
ReceiverSettleMode getRemoteReceiverSettleMode()

@see #setReceiverSettleMode(ReceiverSettleMode)

setRemoteSenderSettleMode
void setRemoteSenderSettleMode(SenderSettleMode remoteSenderSettleMode)

TODO should this be part of the interface?

getProperties
Map!(Symbol, Object) getProperties()

Gets the local link properties.

setProperties
void setProperties(Map!(Symbol, Object) properties)

Sets the local link properties, to be conveyed to the peer via the Attach frame when attaching the link to the session.

getRemoteProperties
Map!(Symbol, Object) getRemoteProperties()

Gets the remote link properties, as conveyed from the peer via the Attach frame when attaching the link to the session.

drained
int drained()
Undocumented in source.
getRemoteCredit
int getRemoteCredit()

Returns a [locally generated] view of credit at the remote peer by considering the current link {@link #getCredit() credit} count as well as the effect of any locally {@link #getQueued() queued} messages.

getDrain
bool getDrain()
Undocumented in source.
detach
void detach()
Undocumented in source.
detached
bool detached()
Undocumented in source.
setOfferedCapabilities
void setOfferedCapabilities(Symbol[] offeredCapabilities)

Sets the local link offered capabilities, to be conveyed to the peer via the Attach frame when attaching the link to the session.

getOfferedCapabilities
Symbol[] getOfferedCapabilities()

Gets the local link offered capabilities.

getRemoteOfferedCapabilities
Symbol[] getRemoteOfferedCapabilities()

Gets the remote link offered capabilities, as conveyed from the peer via the Attach frame when attaching the link to the session.

setDesiredCapabilities
void setDesiredCapabilities(Symbol[] desiredCapabilities)

Sets the local link desired capabilities, to be conveyed to the peer via the Attach frame when attaching the link to the session.

getDesiredCapabilities
Symbol[] getDesiredCapabilities()

Gets the local link desired capabilities.

getRemoteDesiredCapabilities
Symbol[] getRemoteDesiredCapabilities()

Gets the remote link desired capabilities, as conveyed from the peer via the Attach frame when attaching the link to the session.

setMaxMessageSize
void setMaxMessageSize(UnsignedLong maxMessageSize)

Sets the local link max message size, to be conveyed to the peer via the Attach frame when attaching the link to the session. Null or 0 means no limit.

getMaxMessageSize
UnsignedLong getMaxMessageSize()

Gets the local link max message size.

getRemoteMaxMessageSize
UnsignedLong getRemoteMaxMessageSize()

Gets the remote link max message size, as conveyed from the peer via the Attach frame when attaching the link to the session.

Meta