From 15d904b98863850486c67b862ddbe764f00ab192 Mon Sep 17 00:00:00 2001 From: luozukai Date: Thu, 23 May 2019 14:51:29 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=B6=88=E6=81=AF][=E4=BF=AE=E6=94=B9][?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E9=87=8D=E8=AF=95=E6=9C=BA=E5=88=B6]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/iformall/mq/MqBaseConsumer.java | 1 + 1 file changed, 1 insertion(+) diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index 95a6128ff..6e5b869b9 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -92,6 +92,7 @@ public class MqBaseConsumer { if(null != baseMsg){ if(baseMsg.getDelayTimeLevel() < 4){ + Thread.sleep(5000); baseMsg.setDelayTimeLevel(baseMsg.getDelayTimeLevel()+1); mqBaseProducer.sendMessage(baseMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); }else{