From c9c9bde983d6b77d44d75ce9a0eba87a1aef55e2 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Sun, 13 Nov 2022 23:48:39 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 10 +++++++++- 1 files changed, 9 insertions(+), 1 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 36b35d8..95bd8f7 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java @@ -34,6 +34,14 @@ */ @RabbitListener(queues = QueueConstants.TFC_NEW_PRICE) public void tfcNewPrice(String data) { - dappSystemService.tfcNewPrice(data); +// dappSystemService.tfcNewPrice(data); + } + + /** + * @param data + */ + @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT) + public void feeDistribute(String data) { + dappSystemService.feeDistribute(data); } } -- Gitblit v1.9.1