Receiver

interface Receiver : Link {

}

Members

Functions

advance bool advance(): {@inheritDoc}
drain void drain(int credit): Undocumented in source.
draining bool draining(): Undocumented in source.
flow void flow(int credits): Adds the specified number of credits.
recv int recv(byte[] bytes, int offset, int size): Receive message data for the current delivery.
recv int recv(WritableBuffer buffer): Receive message data for the current delivery.
recv ReadableBuffer recv(): Receive message data for the current delivery returning the data in a Readable buffer.
setDrain void setDrain(bool drain): Undocumented in source.

Inherited Members

From Link

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.

Receiver

Members

Functions

Inherited Members

From Link

Meta

Source