ReceiverImpl

Undocumented in source.

Constructors

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

Members

Functions

advance
bool advance()
Undocumented in source. Be warned that the author may not have intended to support it.
clearUnsentCredits
int clearUnsentCredits()
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.
drain
void drain(int credit)
Undocumented in source. Be warned that the author may not have intended to support it.
draining
bool draining()
Undocumented in source. Be warned that the author may not have intended to support it.
flow
void flow(int credits)
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
TransportReceiver getTransportLink()
Undocumented in source. Be warned that the author may not have intended to support it.
hasIncoming
bool hasIncoming()
Undocumented in source. Be warned that the author may not have intended to support it.
recv
int recv(byte[] bytes, int offset, int size)
Undocumented in source. Be warned that the author may not have intended to support it.
recv
int recv(WritableBuffer buffer)
Undocumented in source. Be warned that the author may not have intended to support it.
recv
ReadableBuffer recv()
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.
setTransportLink
void setTransportLink(TransportReceiver transportReceiver)
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 Receiver

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.

drain
void drain(int credit)
Undocumented in source.
advance
bool advance()

{@inheritDoc}

draining
bool draining()
Undocumented in source.
setDrain
void setDrain(bool drain)
Undocumented in source.

Meta