KKSU
2024-12-31 e081193a764667cb091390b034795ee05a36b4fb
refs
author KKSU <15274802129@163.com>
Tuesday, December 31, 2024 15:20 +0800
committer KKSU <15274802129@163.com>
Tuesday, December 31, 2024 15:20 +0800
commite081193a764667cb091390b034795ee05a36b4fb
tree 9110893cfb3b091bee9d910797550b34113a82ec tree | zip | gz
parent 10ac439f9e0abf732901b5b8e3a3b357588bb13f view | diff
feat(rabbitmq): 新增节点升级消息功能

- 在 AgentConsumer 中添加 nodeUpMsg 方法处理节点升级消息
- 在 AgentProducer 中添加 sendNodeUpMsg 方法发送节点升级消息
- 在 AgentServiceImpl 和 ApiMallMemberServiceImpl 中调用 sendNodeUpMsg 方法
- 新增 RUN_VIP_NODE_UP 相关的交换机、队列和路由配置
10 files modified
65 ■■■■■ changed files
src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java 19 ●●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/service/IAgentService.java 2 ●●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java 8 ●●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java 5 ●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/constants/ExchangeConstants.java 1 ●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/constants/QueueConstants.java 1 ●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/constants/RouteKeyConstants.java 1 ●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java 13 ●●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java 7 ●●●●● diff | view | raw | blame | history
src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java 8 ●●●●● diff | view | raw | blame | history