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 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) {
+//        if (isNack) {
-            return false;
+//            return false;
-        } else {
+//        } else {
-            return true;
+//            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 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;
     }
 }