From bb0df5b50b73ee619d808d3fb24d8935434dcb7f Mon Sep 17 00:00:00 2001
From: Wynne <lu_1005@foxmail.com>
Date: Fri, 23 Jul 2021 14:06:37 +0800
Subject: [PATCH] =?UTF-8?q?fix(core):=20mq=E6=B6=88=E6=81=AF=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E=E5=80=BC=E6=9B=B4=E6=96=B0?=
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 eb3213c..1bd8cf9 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 Boolean processImppMessage(Channel channel, Message message) {
+    public void 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 02f9686..9c37fb4 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 Boolean processSchedule(String data, Channel channel, Message message) {
+    public void 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;
     }
 }