| ▼ client | |
| channel.hpp | 信道与信道管理模块的头文件,包含了信道的声明和其管理类的定义。 |
| connection.hpp | 该文件定义了 Connection 类,负责管理客户端连接、信道的创建与关闭以及消息处理。 |
| consume_client.cc | |
| consumer.hpp | 客户端消费者模块 |
| publish_client.cc | |
| worker.hpp | 异步工作线程模块 |
| ▼ common | |
| helper.hpp | 工具类封装 |
| logger.hpp | 异步日志器初始化 |
| msg.pb.cc | |
| msg.pb.h | |
| protocol.pb.cc | |
| protocol.pb.h | |
| threadpool.hpp | |
| ▼ server | |
| binding.hpp | 该文件包含消息队列绑定信息的管理类和结构体定义。 |
| broker.hpp | XuMQ消息队列服务器类的声明文件。 |
| channel.hpp | 信道与信道管理模块的头文件,包含了信道的声明和其管理类的定义。 |
| connection.hpp | 声明了连接类和连接管理类,主要用于管理连接的建立、维护与信道的操作。 |
| consumer.hpp | 消费者管理模块 |
| exchange.hpp | 交换机管理模块,定义了交换机的结构、持久化以及内存管理功能 |
| host.hpp | XuMQ 虚拟机模块定义 |
| message.hpp | 消息队列文件存储的实现 |
| mqserver.cpp | |
| queue.hpp | 消息队列模块的定义和实现 |
| route.hpp | |
| ▼ test | |
| mqbindingtest.cpp | |
| mqchanneltest.cpp | |
| mqconnectiontest.cpp | |
| mqconsumer.cpp | |
| mqexchangetest.cpp | |
| mqfiletest.cpp | |
| mqhosttest.cpp | |
| mqmessagetest.cpp | |
| mqqueuetest.cpp | |
| mqroute.cpp | |
| mqvhostmanagertest.cpp |