C AMQP Protocol Engine API  0.7
 All Classes Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
messenger.h File Reference
Include dependency graph for messenger.h:

Go to the source code of this file.

Macros

#define PN_CUMULATIVE   (0x1)
 

Typedefs

typedef struct pn_messenger_t pn_messenger_t
 
typedef struct pn_subscription_t pn_subscription_t
 
typedef int64_t pn_tracker_t
 

Enumerations

enum  pn_status_t {
  PN_STATUS_UNKNOWN = 0, PN_STATUS_PENDING = 1, PN_STATUS_ACCEPTED = 2, PN_STATUS_REJECTED = 3,
  PN_STATUS_RELEASED = 4, PN_STATUS_MODIFIED = 5, PN_STATUS_ABORTED = 6, PN_STATUS_SETTLED = 7
}
 

Functions

PN_EXTERN pn_messenger_tpn_messenger (const char *name)
 
PN_EXTERN const char * pn_messenger_name (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_certificate (pn_messenger_t *messenger, const char *certificate)
 
PN_EXTERN const char * pn_messenger_get_certificate (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_private_key (pn_messenger_t *messenger, const char *private_key)
 
PN_EXTERN const char * pn_messenger_get_private_key (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_password (pn_messenger_t *messenger, const char *password)
 
PN_EXTERN const char * pn_messenger_get_password (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_trusted_certificates (pn_messenger_t *messenger, const char *cert_db)
 
PN_EXTERN const char * pn_messenger_get_trusted_certificates (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_timeout (pn_messenger_t *messenger, int timeout)
 
PN_EXTERN int pn_messenger_get_timeout (pn_messenger_t *messenger)
 
PN_EXTERN bool pn_messenger_is_blocking (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_blocking (pn_messenger_t *messenger, bool blocking)
 
PN_EXTERN bool pn_messenger_is_passive (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_passive (pn_messenger_t *messenger, bool passive)
 
PN_EXTERN void pn_messenger_free (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_errno (pn_messenger_t *messenger)
 
PN_EXTERN pn_error_tpn_messenger_error (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_get_outgoing_window (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_outgoing_window (pn_messenger_t *messenger, int window)
 
PN_EXTERN int pn_messenger_get_incoming_window (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_set_incoming_window (pn_messenger_t *messenger, int window)
 
PN_EXTERN int pn_messenger_start (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_stop (pn_messenger_t *messenger)
 
PN_EXTERN bool pn_messenger_stopped (pn_messenger_t *messenger)
 
PN_EXTERN pn_subscription_tpn_messenger_subscribe (pn_messenger_t *messenger, const char *source)
 
PN_EXTERN void * pn_subscription_get_context (pn_subscription_t *sub)
 
PN_EXTERN void pn_subscription_set_context (pn_subscription_t *sub, void *context)
 
PN_EXTERN const char * pn_subscription_address (pn_subscription_t *sub)
 
PN_EXTERN int pn_messenger_put (pn_messenger_t *messenger, pn_message_t *msg)
 
PN_EXTERN pn_status_t pn_messenger_status (pn_messenger_t *messenger, pn_tracker_t tracker)
 
PN_EXTERN bool pn_messenger_buffered (pn_messenger_t *messenger, pn_tracker_t tracker)
 
PN_EXTERN int pn_messenger_settle (pn_messenger_t *messenger, pn_tracker_t tracker, int flags)
 
PN_EXTERN pn_tracker_t pn_messenger_outgoing_tracker (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_work (pn_messenger_t *messenger, int timeout)
 
PN_EXTERN int pn_messenger_interrupt (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_send (pn_messenger_t *messenger, int n)
 
PN_EXTERN int pn_messenger_recv (pn_messenger_t *messenger, int limit)
 
PN_EXTERN int pn_messenger_receiving (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_get (pn_messenger_t *messenger, pn_message_t *message)
 
PN_EXTERN pn_tracker_t pn_messenger_incoming_tracker (pn_messenger_t *messenger)
 
PN_EXTERN pn_subscription_tpn_messenger_incoming_subscription (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_accept (pn_messenger_t *messenger, pn_tracker_t tracker, int flags)
 
PN_EXTERN int pn_messenger_reject (pn_messenger_t *messenger, pn_tracker_t tracker, int flags)
 
PN_EXTERN int pn_messenger_outgoing (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_incoming (pn_messenger_t *messenger)
 
PN_EXTERN int pn_messenger_route (pn_messenger_t *messenger, const char *pattern, const char *address)
 
PN_EXTERN int pn_messenger_rewrite (pn_messenger_t *messenger, const char *pattern, const char *address)
 
PN_EXTERN pn_selectable_tpn_messenger_selectable (pn_messenger_t *messenger)
 
PN_EXTERN pn_timestamp_t pn_messenger_deadline (pn_messenger_t *messenger)
 

Detailed Description

The messenger API provides a high level interface for sending and receiving AMQP messages.