consumer.hpp

浏览该文件的文档.

 
 
#pragma once
#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>
 
namespace XuMQ
{
    using ConsumerCallback = std::function<void(const std::string &, const BasicProperties *, const std::string &)>; 
    struct Consumer
    {
        using ptr = std::shared_ptr<Consumer>; 
        std::string tag;                       
        std::string qname;                     
        bool auto_ack;                         
        ConsumerCallback callback;             
 
        Consumer() {}
        Consumer(const std::string &ctag, const std::string &queue_name, bool ack, const ConsumerCallback &cb)
            : tag(ctag), qname(queue_name), auto_ack(ack), callback(cb) {}
    };
}