XuMQ::QueueConsumer类 参考

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

#include <consumer.hpp>

Public 类型
using	ptr = std::shared_ptr< QueueConsumer >
	消费者管理类

Public 成员函数
	QueueConsumer (const std::string &qname)
	构造函数
Consumer::ptr	create (const std::string &ctag, const std::string &queue_name, bool ack, const ConsumerCallback &cb)
	创建一个消费者
void	remove (const std::string &ctag)
	移除一个消费者
Consumer::ptr	choose ()
	获取一个消费者
bool	empty ()
	判断消费者队列是否为空
bool	exists (const std::string &ctag)
	判断消费者是否存在
void	clear ()
	清空

Private 属性
std::string	_qname
	队列名称
std::mutex	_mutex
	互斥锁
uint64_t	_rr_seq
	轮转序号
std::vector< Consumer::ptr >	_consumers
	消费者管理数组

详细描述

以队列为单元的消费者管理类

成员类型定义说明

ptr

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

消费者管理类

构造及析构函数说明

QueueConsumer()

XuMQ::QueueConsumer::QueueConsumer ( const std::string &  qname )

inline

构造函数

参数

qname

队列名称

成员函数说明

choose()

Consumer::ptr XuMQ::QueueConsumer::choose ( )

inline

获取一个消费者

返回

消费者结构管理指针

clear()

void XuMQ::QueueConsumer::clear ( )

inline

清空

create()

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

inline

创建一个消费者

参数

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

返回

消费者结构管理指针

empty()

bool XuMQ::QueueConsumer::empty ( )

inline

判断消费者队列是否为空

返回

为空返回true 不为空返回false

exists()

bool XuMQ::QueueConsumer::exists ( const std::string &  ctag )

inline

判断消费者是否存在

参数

ctag

消费者标识

返回

存在返回true 不存在返回false

remove()

void XuMQ::QueueConsumer::remove ( const std::string &  ctag )

inline

移除一个消费者

参数

ctag

消费者标识

类成员变量说明

_consumers

std::vector<Consumer::ptr> XuMQ::QueueConsumer::_consumers

private

消费者管理数组

_mutex

std::mutex XuMQ::QueueConsumer::_mutex

private

互斥锁

_qname

std::string XuMQ::QueueConsumer::_qname

private

队列名称

_rr_seq

uint64_t XuMQ::QueueConsumer::_rr_seq

private

轮转序号