From 177107b01da03b585aaa347c9fca78c0280f2efe Mon Sep 17 00:00:00 2001 From: luozukai Date: Sat, 29 Jun 2019 15:29:16 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=B6=88=E6=81=AF][=E4=BF=AE=E6=94=B9][?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=AD=BB=E9=94=81]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/mq/impl/RabbitMqMessageProducer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 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 cfc19a689..df79df4d5 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java @@ -39,8 +39,9 @@ public class RabbitMqMessageProducer implements MqBaseProducer { rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data)); - data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode()); - wxMsgRecordMapper.update(data); +// data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode()); +// wxMsgRecordMapper.update(data); + log.info(data.getUuid()+"发送mq成功。"); } catch (Exception e) { log.error("RabbitMqMessageProducer: Send Message Error ", e); }