Commit 064cdd91 authored by maoying's avatar maoying

修改向中心级推送消息格式

parent 96b22d7e
......@@ -297,9 +297,9 @@ public class ContingencyAction implements CustomerAction {
// 将预案的确认消息发送至中心级
if ("CONFIRM".equals(ro.getConfirm())) {
String msg = JSON.toJSONString(event);
log.info("RocketMQ发送的主题是: " + rocketTopic + ", 消息体是: " + msg + "!");
log.info("RocketMQ发送的主题是: " + rocketTopic + ", 消息体是: " + toipResponse.toJsonStr() + "!");
try {
rocketMQService.sendMsg(rocketTopic, "plan_process", msg);
rocketMQService.sendMsg(rocketTopic, "plan_process", toipResponse);
} catch (Exception e) {
log.error(e.getMessage(), e);
throw new RuntimeException("RocketMQ消息发送失败!");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment