src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -47,4 +47,17 @@ } /** * 购买成功 */ @RabbitListener(queues = QueueConstants.RUN_VIP_NODE_UP) public void nodeUpMsg(Long memberId) { try { agentService.nodeUpMsg(memberId); } catch (Exception e) { log.error("消费节点升级异常", e); } } }