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);
        }
    }
}