消费者管理模块更多...

#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>

consumer.hpp 的引用(Include)关系图:

此图展示该文件直接或间接的被哪些文件引用了:

浏览源代码.

类
struct	XuMQ::Consumer
	消费者对象结构更多...

class	XuMQ::QueueConsumer
	以队列为单元的消费者管理类更多...

class	XuMQ::ConsumerManager
	消费者队列管理器更多...

命名空间
namespace	XuMQ

详细描述

消费者管理模块

本文件定义了消费者及其管理类，用于管理队列中的消费者。提供了消费者的创建、移除、选择等功能，以及对消费者队列的管理。主要包括以下结构和类：

Consumer: 表示单个消费者的结构
QueueConsumer: 管理单个队列中的多个消费者
ConsumerManager: 管理所有消费者队列

类

命名空间

详细描述