From bb7728c0259a50d253c13ee1c9bdcd67235f673b Mon Sep 17 00:00:00 2001 From: wulin Date: Sun, 29 Oct 2023 22:10:40 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89demo=E9=98=9F=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/qiuguo/iot/user/api/listener/YunxiListener.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/listener/YunxiListener.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/listener/YunxiListener.java index 2e1e508..f0c3fa8 100644 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/listener/YunxiListener.java +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/listener/YunxiListener.java @@ -18,13 +18,5 @@ import java.io.IOException; @Component @Slf4j public class YunxiListener { - @RabbitListener(queues = YunxiRabbitConst.QUEUE_YUNXI, containerFactory = "simpleRabbitListenerContainerFactory") - public void processYunxiQueue(Channel channel, Message message) throws IOException { - String messageContent = new String(message.getBody(), "UTF-8"); - System.out.println("YunxiListener msg " + messageContent); - //TODO 消费者处理程序 - //处理完毕 手动消息确认 配置需开启 acknowledge-mode: manual - channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); - } }