//
// Created by xajhu on 2021/7/15 0015.
//

#ifndef DAEMON_AGENT_PROJECT_AGENT_MQ_MSG_QUEUE_H
#define DAEMON_AGENT_PROJECT_AGENT_MQ_MSG_QUEUE_H
#ifdef __cplusplus
extern "C" {
#endif

#include "common.h"

typedef struct {
    char cmd[MAX_PATH];
    char key[MAX_PATH];
    char value[MAX_PATH];
} MQ_CMD_MSG, *PMQ_CMD_MSG;

int  mq_init(void);
void mq_uninit(void);

const char *on_msg_cmd(const char *pCmd);
int         mq_data_init();
int         mq_data_send_msg(const char *pMsg);
void       *get_mq_context(void);

#ifdef __cplusplus
}
#endif
#endif    //DAEMON_AGENT_PROJECT_AGENT_MQ_MSG_QUEUE_H