| @@ -62,11 +62,16 @@ 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){ | ||||
| log.error("consum received error: ", e.getMessage()); | |||||
| log.error("consum received error: ", e); | |||||
| //baseMsg.setStatusMessage(e.getMessage()); | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| wxMsgRecordMapper.update(baseMsg); | |||||
| try { | |||||
| log.error("consum received error:{} ", e.getMessage()); | |||||
| log.error("consum received error: ", e); | |||||
| //baseMsg.setStatusMessage(e.getMessage()); | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| wxMsgRecordMapper.update(baseMsg); | |||||
| }catch (Exception e1){ | |||||
| log.error("更新db状态error: ", e1); | |||||
| } | |||||
| // if(null != baseMsg){ | // if(null != baseMsg){ | ||||
| // if(baseMsg.getDelayTimeLevel() < 3){ | // if(baseMsg.getDelayTimeLevel() < 3){ | ||||
| // baseMsg.setDelayTimeLevel(3); //10s后重试 | // baseMsg.setDelayTimeLevel(3); //10s后重试 | ||||