客户端消费者模块 更多...
#include "../common/logger.hpp"
#include "../common/helper.hpp"
#include "../common/msg.pb.h"
#include <iostream>
#include <unordered_map>
#include <vector>
#include <mutex>
#include <memory>
#include <functional>
类 | |
struct | XuMQ::Consumer |
消费者对象结构 更多... | |
命名空间 | |
namespace | XuMQ |
类型定义 | |
using | XuMQ::ConsumerCallback = std::function< void(const std::string &, const BasicProperties *, const std::string &)> |
消费者回调函数 | |
客户端消费者模块
本文件定义了消费者,用于标识客户但中的消费者。