From debfdb88730c40b81d497572f208935b6f439263 Mon Sep 17 00:00:00 2001
From: Neal Hu <nealhu@apache.org>
Date: Sat, 5 May 2018 23:55:57 +0800
Subject: [PATCH] abstract canal client test waiting until running == true

---
 .../com/alibaba/otter/canal/example/AbstractCanalClientTest.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java b/example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java
index fd5f357b..68827b8d 100644
--- a/example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java
+++ b/example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java
@@ -112,6 +112,7 @@ public class AbstractCanalClientTest {
 
     protected void process() {
         int batchSize = 5 * 1024;
+        while (!running);   //waiting until running == true
         while (running) {
             try {
                 MDC.put("destination", destination);