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