diff --git a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java index 1123a9547..70db1c762 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java @@ -47,11 +47,15 @@ public class RabbitMqMessageProducer implements MqBaseProducer , RabbitTemplate. public void confirm(CorrelationData correlationData, boolean ack, String cause) { log.info("confirm:: correlationData {},ack {}, cause {}", correlationData,ack,cause); if(!ack){ - BaseMsg data = new BaseMsg(); - data.setUuid(correlationData.getId()); - data.setMsgStatus(EnumMsgRecordStatus.SEND_FAIL.getCode()); - data.setStatusMessage(cause); - wxMsgRecordMapper.update(data); + try { + BaseMsg data = new BaseMsg(); + data.setUuid(correlationData.getId()); + data.setMsgStatus(EnumMsgRecordStatus.SEND_FAIL.getCode()); + data.setStatusMessage(cause); + wxMsgRecordMapper.update(data); + } catch (Exception e) { + log.error(" RabbitMqMessageProducer.confirm.updateDb Error", e); + } } } @@ -62,18 +66,18 @@ public class RabbitMqMessageProducer implements MqBaseProducer , RabbitTemplate. @Override public void sendMessage(BaseMsg data, String topic, String tags, String keys) { - String tag = UUID.randomUUID().toString(); + String uuid = UUID.randomUUID().toString(); try { - data.setUuid(tag); + data.setUuid(uuid); wxMsgRecordService.save(data); - CorrelationData correlationData = new CorrelationData(tag); + CorrelationData correlationData = new CorrelationData(uuid); rabbitTemplate.convertAndSend(topic, (Object) JsonUtil.obj2Json(data),correlationData); // data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode()); // wxMsgRecordMapper.update(data); log.info(data.getUuid()+"发送mq成功。"); } catch (Exception e) { - log.error(tag + " RabbitMqMessageProducer: Send Message Error", e); + log.error(uuid + " RabbitMqMessageProducer: Send Message Error", e); } } }