8 Commits

Author SHA1 Message Date
qhd
55a6ec0374 重构消息队列连接管理,支持多数据源配置
主要变更:
1. 重构NATS、RabbitMQ和Redis连接管理模块,支持多数据源配置
2. 统一连接管理接口,增加数据源名称参数
3. 优化连接状态检查和错误处理
4. 增加连接池管理和资源清理机制
5. 改进日志输出格式和内容
2026-03-12 08:51:45 +08:00
qhd
69d2ace17f 重构消息队列模块,新增NATS和RabbitMQ连接实现,移除旧版消息队列代码 2026-03-12 08:51:45 +08:00
qhd
ee6d3c9033 重构消息队列模块,新增NATS和RabbitMQ连接实现,移除旧版消息队列代码 2026-03-12 08:51:45 +08:00
qhd
0798dcde37 在NATS消息发布前添加流组创建检查 2026-03-12 08:51:38 +08:00
qhd
5285767964 添加消息队列实现:NATS、RabbitMQ 和 Redis 的 Stream 支持 2026-03-12 08:51:38 +08:00
qhd
a8993de6d5 重构消息队列模块,统一Redis/RabbitMQ/NATS客户端接口,新增消息代理抽象层 2026-03-12 08:51:38 +08:00
qhd
cc940c27b7 优化模块租户检查中间件,重构为函数式实现并添加超级管理员检查;新增MongoDB更新过滤构建工具;修复Redis消息消费错误处理 2026-03-12 08:51:36 +08:00
qhd
d44ed8bf35 redis mq 消息封装 2026-03-12 08:51:25 +08:00