From 21c4edde92e2c7bade302db52329422821f0a8d5 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 08 Jun 2022 19:23:45 +0800 Subject: [PATCH] fix some problem --- src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 6 ++++++ 1 files changed, 6 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java index d232ee8..ab0857a 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java @@ -27,4 +27,10 @@ log.info("收到链上转账消息:{}", batchNo); dappSystemService.onlineTransfer(batchNo); } + + @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT) + public void distrbProfit(String id) { + log.info("收到滑点分配消息:{}", id); + dappSystemService.tradeProfitDistribute(Long.parseLong(id)); + } } -- Gitblit v1.9.1