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); }