| @@ -56,17 +56,20 @@ public class MqBaseConsumer { | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); | baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); | ||||
| wxMsgRecordMapper.update(baseMsg); | wxMsgRecordMapper.update(baseMsg); | ||||
| }catch (Exception e){ | }catch (Exception e){ | ||||
| //todo:测试下 | |||||
| if(null != baseMsg){ | |||||
| if(baseMsg.getDelayTimeLevel() < 3){ | |||||
| baseMsg.setDelayTimeLevel(3); //10s后重试 | |||||
| mqBaseProducer.sendMessage(baseMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); | |||||
| }else{ | |||||
| baseMsg.setStatusMessage(e.getMessage()); | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| wxMsgRecordMapper.update(baseMsg); | |||||
| } | |||||
| } | |||||
| log.error("consum received error: {}", e); | |||||
| baseMsg.setStatusMessage(e.getMessage()); | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| wxMsgRecordMapper.update(baseMsg); | |||||
| // if(null != baseMsg){ | |||||
| // if(baseMsg.getDelayTimeLevel() < 3){ | |||||
| // baseMsg.setDelayTimeLevel(3); //10s后重试 | |||||
| // mqBaseProducer.sendMessage(baseMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); | |||||
| // }else{ | |||||
| // baseMsg.setStatusMessage(e.getMessage()); | |||||
| // baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| // wxMsgRecordMapper.update(baseMsg); | |||||
| // } | |||||
| // } | |||||
| } | } | ||||
| } | } | ||||