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