diff --git a/das/src/main/java/com/das/modules/node/disruptor/TerminalMessageEventHandler.java b/das/src/main/java/com/das/modules/node/disruptor/TerminalMessageEventHandler.java index a5663452..0234d9d0 100644 --- a/das/src/main/java/com/das/modules/node/disruptor/TerminalMessageEventHandler.java +++ b/das/src/main/java/com/das/modules/node/disruptor/TerminalMessageEventHandler.java @@ -21,7 +21,7 @@ public class TerminalMessageEventHandler implements EventHandler> callbackMap = new ConcurrentHashMap<>(16); @Override public void onEvent(TerminalMessage terminalMessage, long sequence, boolean endOfBatch) throws Exception { - log.info("收到消息: {}", terminalMessage.toJsonString()); +// log.info("收到消息: {}", terminalMessage.toJsonString()); if (callbackMap.containsKey(terminalMessage.getCmdId())){ //如果是回调函数,推送到回调函数 callbackMap.get(terminalMessage.getCmdId()).complete(terminalMessage);