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{