SenderImpl

Undocumented in source.

Constructors

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

Members

Functions

abort
void abort()
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.
doFree
void doFree()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteCredit
int getRemoteCredit()
Undocumented in source. Be warned that the author may not have intended to support it.
getTransportLink
TransportSender getTransportLink()
Undocumented in source. Be warned that the author may not have intended to support it.
hasOfferedCredits
bool hasOfferedCredits()
Undocumented in source. Be warned that the author may not have intended to support it.
offer
void offer(int credits)
Undocumented in source. Be warned that the author may not have intended to support it.
send
int send(byte[] bytes, int offset, int length)
Undocumented in source. Be warned that the author may not have intended to support it.
send
int send(ReadableBuffer buffer)
Undocumented in source. Be warned that the author may not have intended to support it.
sendNoCopy
int sendNoCopy(ReadableBuffer buffer)
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.
setTransportLink
void setTransportLink(TransportSender transportLink)
Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From LinkImpl

_head
DeliveryImpl _head;
Undocumented in source.
_tail
DeliveryImpl _tail;
Undocumented in source.
_current
DeliveryImpl _current;
Undocumented in source.
getName
string getName()
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.
postFinal
void postFinal()
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.
modifyEndpoints
void modifyEndpoints()
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.
current
DeliveryImpl current()
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.
getConnectionImpl
ConnectionImpl getConnectionImpl()
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.
getRemoteSource
Source getRemoteSource()
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.
getRemoteTarget
Target getRemoteTarget()
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.
getSource
Source getSource()
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.
getTarget
Target getTarget()
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.
next
Link next(Set!EndpointState local, Set!EndpointState remote)
Undocumented in source. Be warned that the author may not have intended to support it.
getTransportLink
TransportLink getTransportLink()
Undocumented in source.
getCredit
int getCredit()
Undocumented in source. Be warned that the author may not have intended to support it.
addCredit
void addCredit(int credit)
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.
hasCredit
bool hasCredit()
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.
decrementCredit
void decrementCredit()
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.
incrementQueued
void incrementQueued()
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.
getUnsettled
int getUnsettled()
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.
decrementUnsettled
void decrementUnsettled()
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.
getDrain
bool getDrain()
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.
setSenderSettleMode
void setSenderSettleMode(SenderSettleMode senderSettleMode)
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.
setRemoteSenderSettleMode
void setRemoteSenderSettleMode(SenderSettleMode remoteSenderSettleMode)
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.
setReceiverSettleMode
void setReceiverSettleMode(ReceiverSettleMode receiverSettleMode)
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.
setRemoteReceiverSettleMode
void setRemoteReceiverSettleMode(ReceiverSettleMode remoteReceiverSettleMode)
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.
setProperties
void setProperties(Map!(Symbol, Object) properties)
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.
setRemoteProperties
void setRemoteProperties(Map!(Symbol, Object) remoteProperties)
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.
setDesiredCapabilities
void setDesiredCapabilities(Symbol[] desiredCapabilities)
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.
setRemoteDesiredCapabilities
void setRemoteDesiredCapabilities(Symbol[] remoteDesiredCapabilities)
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.
setOfferedCapabilities
void setOfferedCapabilities(Symbol[] offeredCapabilities)
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.
setRemoteOfferedCapabilities
void setRemoteOfferedCapabilities(Symbol[] remoteOfferedCapabilities)
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.
setMaxMessageSize
void setMaxMessageSize(UnsignedLong maxMessageSize)
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.
setRemoteMaxMessageSize
void setRemoteMaxMessageSize(UnsignedLong remoteMaxMessageSize)
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.
getDrained
int getDrained()
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.
head
DeliveryImpl head()
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.
localClose
void localClose()
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.

From Sender

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.

abort
void abort()

Abort the current delivery.

advance
bool advance()

{@inheritDoc}

Meta