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); - } }