public class ProtonDeliveryImpl extends Object implements ProtonDelivery
| Modifier and Type | Method and Description |
|---|---|
org.apache.qpid.proton.engine.Record |
attachments()
Retrieves the attachments record, upon which application items can be set/retrieved.
|
void |
clear() |
ProtonDelivery |
disposition(org.apache.qpid.proton.amqp.transport.DeliveryState state,
boolean settle)
Updates the DeliveryState, and optionally settle the delivery as well.
|
org.apache.qpid.proton.amqp.transport.DeliveryState |
getDefaultDeliveryState() |
io.vertx.proton.impl.ProtonLinkImpl |
getLink() |
io.vertx.proton.impl.ProtonLinkImpl |
getLinkImpl() |
org.apache.qpid.proton.amqp.transport.DeliveryState |
getLocalState()
Gets the current local state for the delivery.
|
int |
getMessageFormat()
Gets the message format for the current delivery.
|
org.apache.qpid.proton.amqp.transport.DeliveryState |
getRemoteState()
Gets the current remote state for the delivery.
|
byte[] |
getTag()
Gets the delivery tag for this delivery
|
ProtonDelivery |
handler(Handler<ProtonDelivery> handler) |
boolean |
isBuffered() |
boolean |
isPartial() |
boolean |
isReadable() |
boolean |
isSettled()
Gets whether the delivery was locally settled yet.
|
boolean |
isUpdated() |
boolean |
isWritable() |
int |
pending() |
boolean |
remotelySettled()
Gets whether the delivery was settled by the remote peer yet.
|
void |
setDefaultDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState state) |
ProtonDelivery |
settle()
Settles the delivery locally.
|
public io.vertx.proton.impl.ProtonLinkImpl getLink()
public void clear()
public org.apache.qpid.proton.amqp.transport.DeliveryState getLocalState()
ProtonDeliverygetLocalState in interface ProtonDeliverypublic boolean isSettled()
ProtonDeliveryisSettled in interface ProtonDeliverypublic boolean remotelySettled()
ProtonDeliveryremotelySettled in interface ProtonDeliverypublic org.apache.qpid.proton.engine.Record attachments()
ProtonDeliveryattachments in interface ProtonDeliverypublic byte[] getTag()
ProtonDeliverygetTag in interface ProtonDeliverypublic void setDefaultDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState state)
public org.apache.qpid.proton.amqp.transport.DeliveryState getDefaultDeliveryState()
public boolean isReadable()
public boolean isUpdated()
public boolean isWritable()
public int pending()
public boolean isPartial()
public org.apache.qpid.proton.amqp.transport.DeliveryState getRemoteState()
ProtonDeliverygetRemoteState in interface ProtonDeliverypublic int getMessageFormat()
ProtonDeliverygetMessageFormat in interface ProtonDeliverypublic boolean isBuffered()
public ProtonDelivery disposition(org.apache.qpid.proton.amqp.transport.DeliveryState state, boolean settle)
ProtonDeliverydisposition in interface ProtonDeliverystate - the delivery state to applysettle - whether to ProtonDelivery.settle() the delivery at the same timepublic ProtonDelivery settle()
ProtonDeliverysettle in interface ProtonDeliverypublic ProtonDelivery handler(Handler<ProtonDelivery> handler)
public io.vertx.proton.impl.ProtonLinkImpl getLinkImpl()
Copyright © 2020. All rights reserved.