From acd9357e5fff3f1b916a3d1b5ea215b69a5d2384 Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Thu, 10 Nov 2022 22:19:51 +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