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