ProtonSenderImpl

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

Constructors

this
this(Sender sender)
Undocumented in source.

Members

Functions

drained
int drained()
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.
isAnonymousSender
bool isAnonymousSender()
Undocumented in source. Be warned that the author may not have intended to support it.
isAutoDrained
bool isAutoDrained()
Undocumented in source. Be warned that the author may not have intended to support it.
isAutoSettle
bool isAutoSettle()
Undocumented in source. Be warned that the author may not have intended to support it.
self
ProtonSenderImpl self()
Undocumented in source. Be warned that the author may not have intended to support it.
send
ProtonDelivery send(Message message)
Undocumented in source. Be warned that the author may not have intended to support it.
send
ProtonDelivery send(Message message, Handler!ProtonDelivery onUpdated)
Undocumented in source. Be warned that the author may not have intended to support it.
send
ProtonDelivery send(byte[] tag, Message message)
Undocumented in source. Be warned that the author may not have intended to support it.
send
ProtonDelivery send(byte[] tag, Message message, Handler!ProtonDelivery onUpdated)
Undocumented in source. Be warned that the author may not have intended to support it.
sendQueueDrainHandler
ProtonSender sendQueueDrainHandler(Handler!ProtonSender drainHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
sendQueueFull
bool sendQueueFull()
Undocumented in source. Be warned that the author may not have intended to support it.
setAnonymousSender
void setAnonymousSender(bool anonymousSender)
Undocumented in source. Be warned that the author may not have intended to support it.
setAutoDrained
ProtonSender setAutoDrained(bool autoDrained)
Undocumented in source. Be warned that the author may not have intended to support it.
setAutoSettle
ProtonSender setAutoSettle(bool autoSettle)
Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From ProtonSender

send
ProtonDelivery send(Message message)

Send the given message.

send
ProtonDelivery send(Message message, Handler!ProtonDelivery onUpdated)

Send the given message, registering the given handler to be called whenever the related delivery is updated due to receiving disposition frames from the peer.

send
ProtonDelivery send(byte[] tag, Message message)

Send the given message, using the supplied delivery tag when creating the delivery.

send
ProtonDelivery send(byte[] tag, Message message, Handler!ProtonDelivery onUpdated)

Send the given message, using the supplied delivery tag when creating the delivery, and registering the given handler to be called whenever the related delivery is updated due to receiving disposition frames from the peer.

sendQueueFull
bool sendQueueFull()

Gets whether the senders outgoing send queue is full, i.e. there is currently no credit to send and send operations will actually buffer locally until there is.

sendQueueDrainHandler
ProtonSender sendQueueDrainHandler(Handler!ProtonSender handler)

Sets a handler called when the send queue is not full, i.e. there is credit available to send messages.

setAutoSettle
ProtonSender setAutoSettle(bool autoSettle)

Sets whether sent deliveries should be automatically locally-settled once they have become remotely-settled by the receiving peer.

isAutoSettle
bool isAutoSettle()

Get whether the receiver is auto settling deliveries.

setAutoDrained
ProtonSender setAutoDrained(bool autoDrained)

Sets whether the link is automatically marked {@link #drained()} after the send queue drain handler callback returns if the receiving peer requested that credit be drained, as indicated by the value of the {@link #getDrain()} flag.

isAutoDrained
bool isAutoDrained()

Get whether the link will automatically be marked drained after the send queue drain handler fires in drain mode.

drained
int drained()

Manually mark the link drained, such that if the receiver has requested the link be drained (as indicated by the value of the {@link #getDrain()} flag) then any remaining credit is discarded and if necessary notice sent to the receiver indicating it has been.

Meta