Sender

interface Sender : Link {

}

Members

Functions

abort void abort(): Abort the current delivery.
advance bool advance(): {@inheritDoc}
offer void offer(int credits): indicates pending deliveries
send int send(byte[] bytes, int offset, int length): Sends some data for the current delivery. The application may call this method multiple times for the same delivery.
send int send(ReadableBuffer buffer): Sends some data for the current delivery. The application may call this method multiple times for the same delivery.
sendNoCopy int sendNoCopy(ReadableBuffer buffer): Sends data to the current delivery attempting not to copy the data unless a previous send has already added data to the Delivery in which case a copy may occur depending on the implementation. <p> Care should be taken when passing ReadableBuffer instances that wrapped pooled bytes as the send does not mean the data will be sent immediately when the transport is flushed so the pooled bytes could be held for longer than expected.

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.

Sender

Members

Functions

Inherited Members

From Link

Meta

Source