diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index f58a2786e..eca04fa9c 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -62,11 +62,16 @@ public class MqBaseConsumer { baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); wxMsgRecordMapper.update(baseMsg); }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(baseMsg.getDelayTimeLevel() < 3){ // baseMsg.setDelayTimeLevel(3); //10s后重试