|
|
@@ -39,8 +39,9 @@ public class RabbitMqMessageProducer implements MqBaseProducer { |
|
|
|
|
|
|
|
|
rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data)); |
|
|
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) { |
|
|
} catch (Exception e) { |
|
|
log.error("RabbitMqMessageProducer: Send Message Error ", e); |
|
|
log.error("RabbitMqMessageProducer: Send Message Error ", e); |
|
|
} |
|
|
} |
|
|
|