src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -42,4 +42,18 @@ public void feeDistribute(String data) { dappSystemService.feeDistribute(data); } @RabbitListener(queues = QueueConstants.TFC_INVITE_PERK_QUEEN) public void invitePerkMsg(Long id) { log.info("消费推荐规则奖励,流水ID:{}", id); dappSystemService.invitePerkMsg(id); } @RabbitListener(queues = QueueConstants.TFC_NODE_PERK_QUEEN) public void nodePerkMsg(Long id) { log.info("消费节点投资,流水ID:{}", id); dappSystemService.nodePerkMsg(id); } }