1 #ifndef SEAF_MQ_MANAGER_H
2 #define SEAF_MQ_MANAGER_H
3 
4 #include <jansson.h>
5 
6 #define SEAFILE_SERVER_CHANNEL_EVENT "seaf_server.event"
7 #define SEAFILE_SERVER_CHANNEL_STATS "seaf_server.stats"
8 
9 struct SeafMqManagerPriv;
10 
11 typedef struct SeafMqManager {
12     struct SeafMqManagerPriv *priv;
13 } SeafMqManager;
14 
15 SeafMqManager *
16 seaf_mq_manager_new ();
17 
18 int
19 seaf_mq_manager_publish_event (SeafMqManager *mgr, const char *channel, const char *content);
20 
21 json_t *
22 seaf_mq_manager_pop_event (SeafMqManager *mgr, const char *channel);
23 
24 #endif
25