|
|
|
@@ -30,8 +30,6 @@ public class MqBaseConsumer { |
|
|
|
private SendMpMsgServiceImpl sendMpMsgService; |
|
|
|
@Autowired |
|
|
|
private SendWeappUniformMsgServiceImpl sendWeappUniformMsgService; |
|
|
|
// @Autowired |
|
|
|
// private MqBaseProducer mqBaseProducer; |
|
|
|
|
|
|
|
public void doMessage(String message) { |
|
|
|
log.info("received message: {}", message); |
|
|
|
@@ -61,14 +59,13 @@ public class MqBaseConsumer { |
|
|
|
} |
|
|
|
baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); |
|
|
|
wxMsgRecordMapper.update(baseMsg); |
|
|
|
}catch (Exception e){ |
|
|
|
}catch (Throwable e){ |
|
|
|
try { |
|
|
|
log.error("consum received error:{} ", e.getMessage()); |
|
|
|
log.error("consum received error: ", e); |
|
|
|
//baseMsg.setStatusMessage(e.getMessage()); |
|
|
|
baseMsg.setStatusMessage(e.getMessage()); |
|
|
|
baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); |
|
|
|
wxMsgRecordMapper.update(baseMsg); |
|
|
|
}catch (Exception e1){ |
|
|
|
}catch (Throwable e1){ |
|
|
|
log.error("更新db状态error: ", e1); |
|
|
|
} |
|
|
|
|
|
|
|
|