XuMQ::MsgQueueManager类 参考

消息队列数据内存管理类 更多...

#include <queue.hpp>

XuMQ::MsgQueueManager 的协作图:

Public 类型
using	ptr = std::shared_ptr< MsgQueueManager >
	消息队列数据内存管理指针

Public 成员函数
	MsgQueueManager (const std::string &dbfile)
	消息队列数据内存管理类 构造函数 从数据库中恢复数据
bool	declareQueue (const std::string &qname, bool qdurable, bool qexclusive, bool qauto_delete, const google::protobuf::Map< std::string, std::string > &qargs)
	声明消息队列
void	deleteQueue (const std::string &name)
	删除消息队列
MsgQueue::ptr	selectQueue (const std::string &name)
	获取指定消息队列
QueueMap &	allQueue ()
	获取所有队列
bool	exists (const std::string &name)
	判断消息队列是否存在
size_t	size ()
	获取消息队列数量
void	clear ()
	清除消息队列

Private 属性
std::mutex	_mutex
	互斥锁
MsgQueueMapper	_mapper
	持久化消息队列管理类
QueueMap	_queues
	全部消息队列信息

详细描述

消息队列数据内存管理类

成员类型定义说明

ptr

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

消息队列数据内存管理指针

构造及析构函数说明

MsgQueueManager()

XuMQ::MsgQueueManager::MsgQueueManager ( const std::string &  dbfile )

inline

消息队列数据内存管理类 构造函数 从数据库中恢复数据

参数

dbfile

数据库名称

函数调用图:

成员函数说明

allQueue()

QueueMap & XuMQ::MsgQueueManager::allQueue ( )

inline

获取所有队列

返回

消息队列映射表

参见

QueueMap

clear()

void XuMQ::MsgQueueManager::clear ( )

inline

清除消息队列

函数调用图:

declareQueue()

bool XuMQ::MsgQueueManager::declareQueue ( const std::string &  qname, bool  qdurable, bool  qexclusive, bool  qauto_delete, const google::protobuf::Map< std::string, std::string > &  qargs  )

inline

声明消息队列

参数

qname	消息队列名称
qdurable	数据持久化标志
qexclusive	独占标志
qauto_delete	自动删除标志
qargs	其他参数

返回

声明成功返回true 失败返回false

函数调用图:

deleteQueue()

void XuMQ::MsgQueueManager::deleteQueue ( const std::string &  name )

inline

删除消息队列

参数

name

消息队列名称

函数调用图:

exists()

bool XuMQ::MsgQueueManager::exists ( const std::string &  name )

inline

判断消息队列是否存在

参数

name

消息队列名称

返回

存在则返回true 不存在返回false

selectQueue()

MsgQueue::ptr XuMQ::MsgQueueManager::selectQueue ( const std::string &  name )

inline

获取指定消息队列

参数

name

消息队列名称

返回

消息队列对象指针

size()

size_t XuMQ::MsgQueueManager::size ( )

inline

获取消息队列数量

返回

消息队列数量

类成员变量说明

_mapper

MsgQueueMapper XuMQ::MsgQueueManager::_mapper

private

持久化消息队列管理类

_mutex

std::mutex XuMQ::MsgQueueManager::_mutex

private

互斥锁

_queues

QueueMap XuMQ::MsgQueueManager::_queues

private

全部消息队列信息