Message-Queues beta 1.1
A Message-Queues based Cpp
 
载入中...
搜索中...
未找到
queue.hpp 文件参考

消息队列模块的定义和实现 更多...

#include "../common/logger.hpp"
#include "../common/helper.hpp"
#include "../common/msg.pb.h"
#include <iostream>
#include <unordered_map>
#include <mutex>
#include <memory>
queue.hpp 的引用(Include)关系图:
此图展示该文件直接或间接的被哪些文件引用了:

浏览源代码.

struct  XuMQ::MsgQueue
 消息队列结构体 更多...
 
class  XuMQ::MsgQueueMapper
 消息队列持久化管理类 将数据存储在sqlite数据库中 更多...
 
class  XuMQ::MsgQueueManager
 消息队列数据内存管理类 更多...
 

命名空间

namespace  XuMQ
 

类型定义

using XuMQ::QueueMap = std::unordered_map< std::string, MsgQueue::ptr >
 消息队列映射表 消息队列名称->消息队列指针
 

详细描述

消息队列模块的定义和实现

本文件定义了消息队列的结构体 MsgQueue 及其管理类 MsgQueueMapperMsgQueueManager

MsgQueue 结构体用于表示一个消息队列,包含其属性和相关操作。 MsgQueueMapper 类负责持久化管理,将消息队列信息存储在 SQLite 数据库中。 MsgQueueManager 类负责在内存中管理消息队列,并提供相应的操作接口。