ProtonReceiverImpl

@author <a href="http://hiramchirino.com">Hiram Chirino</a>

Constructors

this
this(Receiver receiver)
Undocumented in source.

Members

Functions

drain
ProtonReceiver drain(long timeout, Handler!Void completionHandler)
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
ProtonReceiver flow(int credits)
Undocumented in source. Be warned that the author may not have intended to support it.
getPrefetch
int getPrefetch()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteAddress
string getRemoteAddress()
Undocumented in source. Be warned that the author may not have intended to support it.
handleLinkFlow
void handleLinkFlow()
Undocumented in source. Be warned that the author may not have intended to support it.
handler
ProtonReceiver handler(ProtonMessageHandler handler)
Undocumented in source. Be warned that the author may not have intended to support it.
isAutoAccept
bool isAutoAccept()
Undocumented in source. Be warned that the author may not have intended to support it.
onDelivery
void onDelivery()
Undocumented in source. Be warned that the author may not have intended to support it.
open
ProtonReceiver open()
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.
self
ProtonReceiverImpl self()
Undocumented in source. Be warned that the author may not have intended to support it.
setAutoAccept
ProtonReceiver setAutoAccept(bool autoAccept)
Undocumented in source. Be warned that the author may not have intended to support it.
setDrain
ProtonReceiver setDrain(bool drain)
Undocumented in source. Be warned that the author may not have intended to support it.
setPrefetch
ProtonReceiver setPrefetch(int messages)
Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From ProtonReceiver

handler
ProtonReceiver handler(ProtonMessageHandler handler)

Sets the handler to process messages as they arrive. Should be set before opening unless prefetch is disabled and credit is being manually controlled.

setPrefetch
ProtonReceiver setPrefetch(int messages)

Sets the number of message credits the receiver grants and replenishes automatically as messages are delivered.

getPrefetch
int getPrefetch()

Get the current prefetch value.

setAutoAccept
ProtonReceiver setAutoAccept(bool autoAccept)

Sets whether received deliveries should be automatically accepted (and settled) after the message handler runs for them, if no other disposition has been applied during handling.

isAutoAccept
bool isAutoAccept()

Get whether the receiver is auto accepting.

flow
ProtonReceiver flow(int credits)

Grants the given number of message credits to the sender.

drain
ProtonReceiver drain(long timeout, Handler!Void completionHandler)

Initiates a 'drain' of link credit from the remote sender.

Meta