1 #ifndef PROTON_DELIVERY_H
2 #define PROTON_DELIVERY_H 1
29 #include <sys/types.h>
53 #ifndef SWIG // older versions of SWIG choke on this:
PN_EXTERN void pn_delivery_clear(pn_delivery_t *delivery)
Clear the updated flag for a delivery.
PN_EXTERN void pn_delivery_settle(pn_delivery_t *delivery)
Settle a delivery.
size_t size
Definition: delivery.h:49
PN_EXTERN pn_link_t * pn_delivery_link(pn_delivery_t *delivery)
Get the parent link for a delivery object.
PN_EXTERN void * pn_delivery_get_context(pn_delivery_t *delivery)
Get the application context that is associated with a delivery object.
PN_EXTERN bool pn_delivery_readable(pn_delivery_t *delivery)
Check if a delivery is readable.
#define PN_EXTERN
Definition: import_export.h:53
struct pn_delivery_tag_t pn_delivery_tag_t
An AMQP delivery tag.
PN_EXTERN bool pn_delivery_partial(pn_delivery_t *delivery)
Check if a delivery only has partial message data.
PN_EXTERN pn_delivery_tag_t pn_delivery_tag(pn_delivery_t *delivery)
Get the tag for a delivery object.
PN_EXTERN void pn_delivery_set_context(pn_delivery_t *delivery, void *context)
Set a new application context for a delivery object.
struct pn_delivery_t pn_delivery_t
An AMQP Delivery object.
Definition: types.h:231
struct pn_disposition_t pn_disposition_t
Dispositions record the current state and/or final outcome of a transfer.
Definition: disposition.h:51
PN_EXTERN uint64_t pn_delivery_remote_state(pn_delivery_t *delivery)
Get the remote disposition state for a delivery.
PN_EXTERN size_t pn_delivery_pending(pn_delivery_t *delivery)
Get the amount of pending message data for a delivery.
PN_EXTERN pn_disposition_t * pn_delivery_local(pn_delivery_t *delivery)
Get the local disposition for a delivery.
PN_EXTERN void pn_delivery_update(pn_delivery_t *delivery, uint64_t state)
Update the disposition of a delivery.
PN_EXTERN bool pn_delivery_buffered(pn_delivery_t *delivery)
Check if a delivery is buffered.
PN_EXTERN void pn_delivery_dump(pn_delivery_t *delivery)
Utility function for printing details of a delivery.
const char * bytes
Definition: delivery.h:50
PN_EXTERN pn_disposition_t * pn_delivery_remote(pn_delivery_t *delivery)
Get the remote disposition for a delivery.
struct pn_connection_t pn_connection_t
An AMQP Connection object.
Definition: types.h:111
PN_EXTERN uint64_t pn_delivery_local_state(pn_delivery_t *delivery)
Get the local disposition state for a delivery.
PN_EXTERN pn_delivery_t * pn_work_head(pn_connection_t *connection)
Extracts the first delivery on the connection that has pending operations.
PN_EXTERN bool pn_delivery_writable(pn_delivery_t *delivery)
Check if a delivery is writable.
PN_EXTERN pn_delivery_t * pn_work_next(pn_delivery_t *delivery)
Get the next delivery on the connection that needs has pending operations.
PN_EXTERN pn_delivery_t * pn_delivery(pn_link_t *link, pn_delivery_tag_t tag)
Create a delivery on a link.
PN_EXTERN bool pn_delivery_updated(pn_delivery_t *delivery)
Check if a delivery is updated.
struct pn_link_t pn_link_t
An AMQP Link object.
Definition: types.h:141
Disposition API for the proton Engine.
PN_EXTERN bool pn_delivery_settled(pn_delivery_t *delivery)
Check if a delivery is remotely settled.
An AMQP delivery tag.
Definition: delivery.h:48