XuMQ::ConsumerManager类 参考

消费者队列管理器 更多...

#include <consumer.hpp>

Public 类型
using	ptr = std::shared_ptr< ConsumerManager >
	消息队列管理器指针

Public 成员函数
	ConsumerManager ()
	无参构造
void	initQueueConsumer (const std::string &name)
	初始化消费者队列
void	destroyQueueConsumer (const std::string &name)
	销毁消费者队列
Consumer::ptr	create (const std::string &ctag, const std::string &queue_name, bool ack, const ConsumerCallback &cb)
	向指定队列新增消费者
void	remove (const std::string &ctag, const std::string &queue_name)
	移除队列的一个消费者
Consumer::ptr	choose (const std::string &queue_name)
	获取指定队列的消费者
bool	empty (const std::string &queue_name)
	判断指定队列是否为空
bool	exists (const std::string &ctag, const std::string &queue_name)
	判断队列中的消费者是否存在
void	clear ()
	清理

Private 属性
std::mutex	_mutex
std::unordered_map< std::string, QueueConsumer::ptr >	_qconsumers

详细描述

消费者队列管理器

成员类型定义说明

ptr

using XuMQ::ConsumerManager::ptr = std::shared_ptr<ConsumerManager>

消息队列管理器指针

构造及析构函数说明

ConsumerManager()

XuMQ::ConsumerManager::ConsumerManager ( )

inline

无参构造

成员函数说明

choose()

Consumer::ptr XuMQ::ConsumerManager::choose ( const std::string &  queue_name )

inline

获取指定队列的消费者

参数

queue_name

队列名称

返回

消费者指针

clear()

void XuMQ::ConsumerManager::clear ( )

inline

清理

create()

Consumer::ptr XuMQ::ConsumerManager::create ( const std::string &  ctag, const std::string &  queue_name, bool  ack, const ConsumerCallback &  cb  )

inline

向指定队列新增消费者

参数

ctag	消费者标识
queue_name	队列名称
ack	自动确认标志
cb	消费者回调函数

返回

消费者指针

destroyQueueConsumer()

void XuMQ::ConsumerManager::destroyQueueConsumer ( const std::string &  name )

inline

销毁消费者队列

参数

name

队列名称

empty()

bool XuMQ::ConsumerManager::empty ( const std::string &  queue_name )

inline

判断指定队列是否为空

参数

queue_name

队列名称

返回

为空返回true 不为空返回false

exists()

bool XuMQ::ConsumerManager::exists ( const std::string &  ctag, const std::string &  queue_name  )

inline

判断队列中的消费者是否存在

参数

ctag	消费者标识
queue_name	队列名称

返回

存在返回true 不存在返回false

initQueueConsumer()

void XuMQ::ConsumerManager::initQueueConsumer ( const std::string &  name )

inline

初始化消费者队列

参数

name

队列名称

remove()

void XuMQ::ConsumerManager::remove ( const std::string &  ctag, const std::string &  queue_name  )

inline

移除队列的一个消费者

参数

ctag	消费者标识
queue_name	队列名称

类成员变量说明

_mutex

std::mutex XuMQ::ConsumerManager::_mutex

private

_qconsumers

std::unordered_map<std::string, QueueConsumer::ptr> XuMQ::ConsumerManager::_qconsumers

private