▼ 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 |