diff --git a/src/main/java/com/bootdo/datasend/dianxin/listener/MessageConsumer.java b/src/main/java/com/bootdo/datasend/dianxin/listener/MessageConsumer.java index 03efb93..31093d9 100644 --- a/src/main/java/com/bootdo/datasend/dianxin/listener/MessageConsumer.java +++ b/src/main/java/com/bootdo/datasend/dianxin/listener/MessageConsumer.java @@ -13,7 +13,7 @@ public class MessageConsumer { //测试消费kafka // 监听队列 "myQueue" - @RabbitListener(queues = "myQueue") +// @RabbitListener(queues = "myQueue") public void receiveMessage(JSONObject message) { try { // 处理接收到的消息