Просмотр исходного кода

[消息][修改][添加重试机制]

release_toaliyun_real
luozukai 7 лет назад
Родитель
Сommit
15d904b988
1 измененных файлов: 1 добавлений и 0 удалений
  1. +1
    -0
      mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java

+ 1
- 0
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{


Загрузка…
Отмена
Сохранить