chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed issue #619, improve code

Browse Source
This commit is contained in:
七锋
2018-05-07 10:18:25 +08:00
parent e0fa8e0f72
commit c8f1d54fa1
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java
View File

@@ -4,7 +4,6 @@ import java.text.SimpleDateFormat;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import com.alibaba.otter.canal.client.impl.ClusterCanalConnector;
import org.apache.commons.lang.SystemUtils; import org.apache.commons.lang.SystemUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -13,6 +12,7 @@ import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import com.alibaba.otter.canal.client.CanalConnector; import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.impl.ClusterCanalConnector;
import com.alibaba.otter.canal.protocol.CanalEntry.Column; import com.alibaba.otter.canal.protocol.CanalEntry.Column;
import com.alibaba.otter.canal.protocol.CanalEntry.Entry; import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType; import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
@@ -84,8 +84,8 @@ public class AbstractCanalClientTest {
}); });
thread.setUncaughtExceptionHandler(handler); thread.setUncaughtExceptionHandler(handler);
thread.start();
running = true; running = true;
thread.start();
} }
protected void stop() { protected void stop() {
@@ -112,7 +112,6 @@ public class AbstractCanalClientTest {
protected void process() { protected void process() {
int batchSize = 5 * 1024; int batchSize = 5 * 1024;
while (!running); //waiting until running == true
while (running) { while (running) {
try { try {
MDC.put("destination", destination); MDC.put("destination", destination);