fix(core): 还原mq返回值

还原mq返回值

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;
+        }
     }
 
     /**

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;
     }
 }