public interface ProtonSender extends ProtonLink<ProtonSender>
| Modifier and Type | Method and Description |
|---|---|
boolean |
isAutoSettle()
Get whether the receiver is auto settling deliveries.
|
ProtonDelivery |
send(byte[] tag,
org.apache.qpid.proton.message.Message message)
Send the given message, using the supplied delivery tag when creating the delivery.
|
ProtonDelivery |
send(byte[] tag,
org.apache.qpid.proton.message.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.
|
ProtonDelivery |
send(org.apache.qpid.proton.message.Message message)
Send the given message.
|
ProtonDelivery |
send(org.apache.qpid.proton.message.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.
|
ProtonSender |
sendQueueDrainHandler(Handler<ProtonSender> handler)
Sets a handler called when the send queue is not full, i.e.
|
boolean |
sendQueueFull()
Gets whether the senders outgoing send queue is full, i.e.
|
ProtonSender |
setAutoSettle(boolean autoSettle)
Sets whether sent deliveries should be automatically locally-settled once they have become remotely-settled by the
receiving peer.
|
attachments, close, closeHandler, getCondition, getQoS, getRemoteCondition, getRemoteQoS, getRemoteSource, getRemoteTarget, getSession, getSource, getTarget, isOpen, open, openHandler, setCondition, setQoS, setSource, setTargetProtonDelivery send(org.apache.qpid.proton.message.Message message)
message - the message to sendProtonDelivery send(org.apache.qpid.proton.message.Message message, Handler<ProtonDelivery> onUpdated)
message - the message to sendonUpdated - handler called when a disposition update is received for the deliveryProtonDelivery send(byte[] tag, org.apache.qpid.proton.message.Message message)
tag - the tag to use for the delivery used to send the messagemessage - the message to sendProtonDelivery send(byte[] tag, org.apache.qpid.proton.message.Message message, Handler<ProtonDelivery> onUpdated)
tag - the tag to use for the delivery used to send the messagemessage - the message to sendonUpdated - handler called when a disposition update is received for the deliveryboolean sendQueueFull()
ProtonSender sendQueueDrainHandler(Handler<ProtonSender> handler)
handler - the handler to process messagesProtonSender setAutoSettle(boolean autoSettle)
autoSettle - whether deliveries should be auto settled locally after being settled by the receiverboolean isAutoSettle()
setAutoSettle(boolean)Copyright © 2016. All rights reserved.