From 7bedece4e6f49698cd5504d32353f6c356cf857d Mon Sep 17 00:00:00 2001 From: wulin Date: Sun, 29 Oct 2023 22:25:45 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E6=8E=89=E8=AE=A2=E9=98=85MQ?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iot/user/api/listener/YunxiListener.java | 30 ------------------- 1 file changed, 30 deletions(-) delete mode 100644 iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/listener/YunxiListener.java 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 deleted file mode 100644 index 2e1e508..0000000 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/listener/YunxiListener.java +++ /dev/null @@ -1,30 +0,0 @@ -package com.qiuguo.iot.user.api.listener; - -import com.qiuguo.iot.data.constants.YunxiRabbitConst; -import com.rabbitmq.client.AMQP; -import com.rabbitmq.client.Channel; -import lombok.extern.slf4j.Slf4j; -import org.springframework.amqp.core.Message; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.stereotype.Component; - -import java.io.IOException; - -/** - * @author simon - * @date 2023/9/26 - * @description - **/ -@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); - } -}