From 4004aa1090b56756f6910699f09780b04af1ad14 Mon Sep 17 00:00:00 2001
From: chenyouting <514333061@qq.com>
Date: Sat, 13 Sep 2025 16:51:56 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9C=A8=E7=BA=BF=E7=8A=B6=E6=80=81=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9=E4=BC=98=E5=8C=962?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/fuyuanshen/global/queue/MqttMessageConsumer.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java b/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
index 1d30483d..998695e2 100644
--- a/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
+++ b/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
@@ -68,7 +68,7 @@ public class MqttMessageConsumer {
     public void consumeMessages() {
         String queueKey = MqttMessageQueueConstants.MQTT_MESSAGE_QUEUE_KEY;
         String threadName = Thread.currentThread().getName();
-        log.info("消息消费者线程 {} 开始监听队列: {}", threadName, queueKey);
+//        log.info("消息消费者线程 {} 开始监听队列: {}", threadName, queueKey);
         
         try {
             while (!Thread.currentThread().isInterrupted() && !messageConsumerPool.isShutdown()) {
@@ -81,7 +81,7 @@ public class MqttMessageConsumer {
                 );
                 
                 if (message != null) {
-                    log.info("线程 {} 从队列中获取到消息，提交到处理线程池: {}", threadName, message);
+//                    log.info("线程 {} 从队列中获取到消息，提交到处理线程池: {}", threadName, message);
                     // 将消息处理任务提交到处理线程池
                     messageProcessorPool.submit(() -> processMessage(message));
                 }