From 171bc62edf4fa8db25201f363e5c173dd84dc2bf Mon Sep 17 00:00:00 2001 From: luozukai Date: Mon, 16 Sep 2019 11:12:54 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BF=AE=E6=94=B9][=E7=BB=93=E7=AE=97?= =?UTF-8?q?=E5=8D=95][=E4=BC=98=E5=8C=96=E6=B6=88=E6=81=AF=E5=9B=9E?= =?UTF-8?q?=E8=B0=83]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mq/impl/RabbitMqMessageProducer.java | 22 +++++++++++-------- 1 file changed, 13 insertions(+), 9 deletions(-) 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); } } }