Commit 2e1441a5 authored by KeYong's avatar KeYong

注释掉kafka

parent c42449a1
......@@ -306,12 +306,12 @@ public class ContingencyAction implements CustomerAction {
}
// kafka消息发送至南瑞平台
try {
iKafkaProducer.sendMessage(rocketTopic, "plan_process", toipResponse);
} catch (Exception e) {
log.error(e.getMessage(), e);
throw new RuntimeException("Kafka消息发送失败!");
}
// try {
// iKafkaProducer.sendMessage(rocketTopic, "plan_process", toipResponse);
// } catch (Exception e) {
// log.error(e.getMessage(), e);
// throw new RuntimeException("Kafka消息发送失败!");
// }
}
} else if ("websocket".equals(pushType.toLowerCase())) {
action.execute(msgType, contingency);
......
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