From 2de78bd7698293328f481b50ffb6ee971c6118b3 Mon Sep 17 00:00:00 2001 From: bgy Date: Wed, 15 Jul 2026 09:11:14 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=8F=91=E9=80=81=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E8=BD=AC=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/topsail/influxdb/rabbitmq/AmqpListener.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/topsail/influxdb/rabbitmq/AmqpListener.java b/src/main/java/com/topsail/influxdb/rabbitmq/AmqpListener.java index 1e59992..d870272 100644 --- a/src/main/java/com/topsail/influxdb/rabbitmq/AmqpListener.java +++ b/src/main/java/com/topsail/influxdb/rabbitmq/AmqpListener.java @@ -40,7 +40,7 @@ public class AmqpListener { * @param channel * @throws Exception */ -// @RabbitListener(queues = "shengdilandevicedataall") + @RabbitListener(queues = "shengdilandevicedataall") public void deviceDataMqListener(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag, Channel channel) throws Exception { if (StringUtils.isEmpty(message)) { channel.basicAck(deliveryTag, false); @@ -93,7 +93,7 @@ public class AmqpListener { } } } -// @RabbitListener(queues = "shengdilandevicedataback") + @RabbitListener(queues = "shengdilandevicedataback") public void deviceDataMqListenerForBackup(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag, Channel channel) throws Exception { if (StringUtils.isEmpty(message)) { channel.basicAck(deliveryTag, false); @@ -154,7 +154,7 @@ public class AmqpListener { * @param channel * @throws Exception */ -// @RabbitListener(queues = "shengdilandevicelogall") + @RabbitListener(queues = "shengdilandevicelogall") public void deviceLogMqListener(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag, Channel channel) throws Exception { if (StringUtils.isEmpty(message)) { channel.basicAck(deliveryTag, false);