ProtonSender

@author <a href="http://tfox.org">Tim Fox</a>

interface ProtonSender : ProtonLink!ProtonSender {

ProtonDelivery send(Message message);

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

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

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

bool sendQueueFull();

ProtonSender sendQueueDrainHandler(Handler!ProtonSender handler);

ProtonSender setAutoSettle(bool autoSettle);

bool isAutoSettle();

ProtonSender setAutoDrained(bool autoDrained);

bool isAutoDrained();

int drained();

}

Members

Functions

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.
isAutoDrained bool isAutoDrained(): Get whether the link will automatically be marked drained after the send queue drain handler fires in drain mode.
isAutoSettle bool isAutoSettle(): Get whether the receiver is auto settling deliveries.
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.
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.
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.
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.
setAutoSettle ProtonSender setAutoSettle(bool autoSettle): Sets whether sent deliveries should be automatically locally-settled once they have become remotely-settled by the receiving peer.

ProtonSender

Members

Functions

Meta

Source