rabbit.h

Go to the documentation of this file.

 
#pragma once
 
#include <common/xroad_xml.h>
#include <stdint.h>
#include <string.h>
#include <amqp.h>
 
#ifdef __cplusplus
extern "C"
{
#endif
 
typedef struct rabbit_s rabbit_t;
 
typedef struct
{
   void* ctx;                                             
   void (*on_connected)(rabbit_t*, void*);                
   void (*on_disconnected)(rabbit_t*, void*);             
   bool (*on_msg)(rabbit_t*, uint64_t, const amqp_basic_properties_t*, const void*, size_t, void*);
} rabbit_callback_t;
 
rabbit_t* rabbit_create(xroad_xml_tag_t cfg, rabbit_callback_t cback);
 
xroad_errno_t rabbit_reconfig(rabbit_t* r, xroad_xml_tag_t cfg);
 
void rabbit_destroy(rabbit_t* r);
 
xroad_errno_t rabbit_start(rabbit_t* r);
 
xroad_errno_t rabbit_stop(rabbit_t* r);
 
xroad_errno_t rabbit_send(rabbit_t* r, xroad_str_t exchange, xroad_str_t binding_key,
      const amqp_basic_properties_t* props, void* data, size_t len);
 
xroad_errno_t rabbit_ack(rabbit_t* r, uint64_t delivery_tag);
 
xroad_errno_t rabbit_queue_bind(rabbit_t* r, xroad_str_t queue, xroad_str_t exchange, xroad_str_t binding_key);
 
xroad_errno_t rabbit_queue_unbind(rabbit_t* r, xroad_str_t queue, xroad_str_t exchange, xroad_str_t binding_key);
 
#ifdef __cplusplus
}
#endif