From 54f8d4b5e01fbace30d1081cbd8927d8eb2cebf1 Mon Sep 17 00:00:00 2001
From: shahaibo <1023316923@qq.com>
Date: Wed, 10 Jul 2024 09:30:40 +0800
Subject: [PATCH] =?UTF-8?q?TASK:=E6=B6=88=E8=B4=B9=E5=BC=80=E5=90=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ai/da/common/RabbitMQ/SRConsumer.java | 24 +++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/ai/da/common/RabbitMQ/SRConsumer.java b/src/main/java/com/ai/da/common/RabbitMQ/SRConsumer.java
index b8ba32f2..6ad261bd 100644
--- a/src/main/java/com/ai/da/common/RabbitMQ/SRConsumer.java
+++ b/src/main/java/com/ai/da/common/RabbitMQ/SRConsumer.java
@@ -218,17 +218,17 @@ public class SRConsumer {
         taskListService.updateTaskStatusOrOutputRedis(uniqueId, "fail", null);
     }
 
-//    @RabbitListener(queues = MQConfig.SR_QUEUE)
-//    @RabbitHandler
-//    public void SRConsumer1(Message msg, Channel channel) {
-//        superResolution(msg, channel, "consumer 1");
-//    }
-//
-//
-//    @RabbitListener(queues = MQConfig.SR_RESULT_QUEUE)
-//    @RabbitHandler
-//    public void SRResultConsumer1(Message msg, Channel channel) {
-//        getSRResult(msg, channel, "consumer 1");
-//    }
+    @RabbitListener(queues = MQConfig.SR_QUEUE)
+    @RabbitHandler
+    public void SRConsumer1(Message msg, Channel channel) {
+        superResolution(msg, channel, "consumer 1");
+    }
+
+
+    @RabbitListener(queues = MQConfig.SR_RESULT_QUEUE)
+    @RabbitHandler
+    public void SRResultConsumer1(Message msg, Channel channel) {
+        getSRResult(msg, channel, "consumer 1");
+    }
 
 }