src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | ●●●●● patch | view | raw | blame | history |
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -52,9 +52,13 @@ dappSystemService.achieveTree(Long.parseLong(id)); } /** * 生产者在tfc应用 * @param data */ @RabbitListener(queues = QueueConstants.TFC_NEW_PRICE) public void tfcNewPrice(String data) { log.info("收到最新价消息"); dappSystemService.tfcNewPrice(data); } }