src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -72,4 +72,13 @@ log.info("消费转账拨币:{}", id); dappSystemService.bnbTransfer(id); } /**代理升级 * @param inviteId */ @RabbitListener(queues = QueueConstants.QUEUE_BNB_AGENT_UP) public void agentUp(String inviteId) { log.info("代理升级:{}", inviteId); dappSystemService.agentUp(inviteId); } }