src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -48,6 +48,19 @@ /** * 充值成功 */ @RabbitListener(queues = QueueConstants.RUN_VIP_OPERATION_CHARGE_BALANCE) public void chargeSuccessMsg(Long chargeId) { try { agentService.chargeSuccessMsg(chargeId); } catch (Exception e) { log.error("消费充值异常", e); } } /** * 节点升级 */ @RabbitListener(queues = QueueConstants.RUN_VIP_NODE_UP)