diff --git a/common/src/test/java/com/alibaba/otter/canal/common/ServerRunningTest.java b/common/src/test/java/com/alibaba/otter/canal/common/ServerRunningTest.java index 942ab81b..ae0af9cc 100644 --- a/common/src/test/java/com/alibaba/otter/canal/common/ServerRunningTest.java +++ b/common/src/test/java/com/alibaba/otter/canal/common/ServerRunningTest.java @@ -106,21 +106,21 @@ public class ServerRunningTest extends AbstractZkTest { runningMonitor.setListener(new ServerRunningListener() { public void processActiveEnter() { - System.out.println(String.format("cid:%s ip:%s:%s has start", ip, port)); + System.out.println(String.format("ip:%s:%s has start", ip, port)); countLatch.countDown(); } public void processActiveExit() { - System.out.println(String.format("cid:%s ip:%s:%s has stop", ip, port)); + System.out.println(String.format("ip:%s:%s has stop", ip, port)); countLatch.countDown(); } public void processStart() { - System.out.println(String.format("cid:%s ip:%s:%s processStart", ip, port)); + System.out.println(String.format("ip:%s:%s processStart", ip, port)); } public void processStop() { - System.out.println(String.format("cid:%s ip:%s:%s processStop", ip, port)); + System.out.println(String.format("ip:%s:%s processStop", ip, port)); } }); diff --git a/server/src/test/java/com/alibaba/otter/canal/server/ProtocolTest.java b/protocol/src/test/java/com/alibaba/otter/canal/protocol/ProtocolTest.java similarity index 98% rename from server/src/test/java/com/alibaba/otter/canal/server/ProtocolTest.java rename to protocol/src/test/java/com/alibaba/otter/canal/protocol/ProtocolTest.java index da479e20..dae8b115 100644 --- a/server/src/test/java/com/alibaba/otter/canal/server/ProtocolTest.java +++ b/protocol/src/test/java/com/alibaba/otter/canal/protocol/ProtocolTest.java @@ -1,4 +1,4 @@ -package com.alibaba.otter.canal.server; +package com.alibaba.otter.canal.protocol; import com.alibaba.otter.canal.protocol.CanalEntry.Entry; import com.alibaba.otter.canal.protocol.CanalEntry.EntryType; diff --git a/server/src/test/java/com/alibaba/otter/canal/server/SecurityUtilTest.java b/protocol/src/test/java/com/alibaba/otter/canal/protocol/SecurityUtilTest.java similarity index 94% rename from server/src/test/java/com/alibaba/otter/canal/server/SecurityUtilTest.java rename to protocol/src/test/java/com/alibaba/otter/canal/protocol/SecurityUtilTest.java index 69e60ae4..92c5df4c 100644 --- a/server/src/test/java/com/alibaba/otter/canal/server/SecurityUtilTest.java +++ b/protocol/src/test/java/com/alibaba/otter/canal/protocol/SecurityUtilTest.java @@ -1,4 +1,4 @@ -package com.alibaba.otter.canal.server; +package com.alibaba.otter.canal.protocol; import java.security.NoSuchAlgorithmException;