Skip to content

Commit 88d472e

Browse files
author
Junwang Zhao
authored
move protocol test to protocol test directory (#3864)
1. move the protocol test to right directory 2. fix wrong string format params count Signed-off-by: 元组 <zhaojunwang.zjw@alibaba-inc.com>
1 parent 2987d08 commit 88d472e

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

common/src/test/java/com/alibaba/otter/canal/common/ServerRunningTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -106,21 +106,21 @@ private ServerRunningMonitor buildServerRunning(final CountDownLatch countLatch,
106106
runningMonitor.setListener(new ServerRunningListener() {
107107

108108
public void processActiveEnter() {
109-
System.out.println(String.format("cid:%s ip:%s:%s has start", ip, port));
109+
System.out.println(String.format("ip:%s:%s has start", ip, port));
110110
countLatch.countDown();
111111
}
112112

113113
public void processActiveExit() {
114-
System.out.println(String.format("cid:%s ip:%s:%s has stop", ip, port));
114+
System.out.println(String.format("ip:%s:%s has stop", ip, port));
115115
countLatch.countDown();
116116
}
117117

118118
public void processStart() {
119-
System.out.println(String.format("cid:%s ip:%s:%s processStart", ip, port));
119+
System.out.println(String.format("ip:%s:%s processStart", ip, port));
120120
}
121121

122122
public void processStop() {
123-
System.out.println(String.format("cid:%s ip:%s:%s processStop", ip, port));
123+
System.out.println(String.format("ip:%s:%s processStop", ip, port));
124124
}
125125

126126
});

server/src/test/java/com/alibaba/otter/canal/server/ProtocolTest.java renamed to protocol/src/test/java/com/alibaba/otter/canal/protocol/ProtocolTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.alibaba.otter.canal.server;
1+
package com.alibaba.otter.canal.protocol;
22

33
import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
44
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;

server/src/test/java/com/alibaba/otter/canal/server/SecurityUtilTest.java renamed to protocol/src/test/java/com/alibaba/otter/canal/protocol/SecurityUtilTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.alibaba.otter.canal.server;
1+
package com.alibaba.otter.canal.protocol;
22

33
import java.security.NoSuchAlgorithmException;
44

0 commit comments

Comments
 (0)