From c54f0c60faae496e0fd989b281b776b69b65a87a Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Sat, 27 Aug 2022 22:29:30 +0800 Subject: [PATCH] finish sde --- src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 9 +++++++++ 1 files changed, 9 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 6af3e87..8c1ff81 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java @@ -51,4 +51,13 @@ log.info("收到业绩树消息"); dappSystemService.achieveTree(Long.parseLong(id)); } + + /** + * 生产者在tfc应用 + * @param data + */ + @RabbitListener(queues = QueueConstants.TFC_NEW_PRICE) + public void tfcNewPrice(String data) { + dappSystemService.tfcNewPrice(data); + } } -- Gitblit v1.9.1