From 004aab9426b8713eb3a3cbab800b0860bb65f7a1 Mon Sep 17 00:00:00 2001
From: Wynne <lu_1005@foxmail.com>
Date: Fri, 23 Jul 2021 14:25:08 +0800
Subject: [PATCH] =?UTF-8?q?fix(core):=20=E8=BF=98=E5=8E=9Fmq=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

还原mq返回值
---
 .../i3plus/core/apiservice/mq/PojoVersionQueueReceiver.java  | 12 ++++++------
 .../i3plus/core/apiservice/mq/ScheduleQueueReceiver.java     |  6 +++---
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/PojoVersionQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/PojoVersionQueueReceiver.java
index 1bd8cf9..eb3213c 100644
--- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/PojoVersionQueueReceiver.java
+++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/PojoVersionQueueReceiver.java
@@ -72,7 +72,7 @@ public class PojoVersionQueueReceiver {
     }
 
     @RabbitListener(queues = QUEUE_IMPP_POJO_VERSION)
-    public void processImppMessage(Channel channel, Message message) {
+    public Boolean processImppMessage(Channel channel, Message message) {
         boolean isNack = false;
         try {
             byte[] messageBody = message.getBody();
@@ -179,11 +179,11 @@ public class PojoVersionQueueReceiver {
                 LOGGER.error("Pojo Version MQ ACK Error Message :{}", e.getMessage());
             }
         }
-//        if (isNack) {
-//            return false;
-//        } else {
-//            return true;
-//        }
+        if (isNack) {
+            return false;
+        } else {
+            return true;
+        }
     }
 
     /**
diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java
index 9c37fb4..02f9686 100644
--- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java
+++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java
@@ -61,7 +61,7 @@ public class ScheduleQueueReceiver {
      * @param message 消息
      */
     @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_SCHEDULE)
-    public void processSchedule(String data, Channel channel, Message message) {
+    public Boolean processSchedule(String data, Channel channel, Message message) {
         try {
             SysLogTaskTime logTaskTime = JsonUtilTool.decode(data, SysLogTaskTime.class);
             LOGGER.debug("【MQ-QUEUE_IMPP_SCHEDULE】数据接收成功：{}", logTaskTime);
@@ -128,7 +128,7 @@ public class ScheduleQueueReceiver {
 
             //信息已处理
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-//            return true;
+            return true;
         } catch (IOException e) {
             LOGGER.error("【MQ-IMPP_SCHEDULE_QUEUE】处理出错：{}", e.getMessage(), e);
             //丢弃这条消息
@@ -139,6 +139,6 @@ public class ScheduleQueueReceiver {
                 e1.printStackTrace();
             }
         }
-//        return false;
+        return false;
     }
 }