Message Broker  0.29.2
channel.h
1 
13 #ifndef MDB_CHANNEL_H
14 #define MDB_CHANNEL_H
15 
16 #include <stdint.h>
17 #include <stdlib.h>
18 #include <time.h>
19 
20 #include "mdb/channel_config.h"
21 #include "mdb/connection.h"
22 #include "mdb/error.h"
23 #include "mdb/message.h"
24 #include "mdb/signatures.h"
25 
26 #ifdef __cplusplus
27 extern "C" {
28 #endif
29 
30 typedef struct mdb_channel mdb_channel_t;
31 
45 mdb_channel_t *mdb_channel_create_async(mdb_connection_t *connection,
46  mdb_channel_config_t *config,
47  mdb_on_done_t on_done, void *user_data,
48  mdb_error_t **error);
49 
72 bool mdb_channel_publish_async(mdb_channel_t *self, mdb_message_t *message,
73  mdb_on_done_t on_done, void *user_data,
74  mdb_error_t **error);
75 
84 void mdb_channel_destroy(mdb_channel_t **self);
85 #ifdef __cplusplus
86 }
87 #endif
88 
89 #endif
Definition: error.h:43