src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -44,4 +44,20 @@ public void feeDistribute(String data) { dappSystemService.feeDistribute(data); } /**层级奖励分发消息 * @param id */ @RabbitListener(queues = QueueConstants.QUEUE_LEVEL_PROFIT) public void levelProfit(Long id) { dappSystemService.levelProfit(id); } /**计算是否有人出局分发消息 * @param id */ @RabbitListener(queues = QueueConstants.QUEUE_MEMBER_OUT) public void memberOut(Long id) { dappSystemService.memberOut(id); } }