From 0bb629f780f01bde04db7d8c5af25b23a1e05472 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 07 Jun 2024 13:07:11 +0800 Subject: [PATCH] 将监听充值新建一个项目 --- 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