From 4022aa8b5ab1ae3299906c140896c9f7805f42c3 Mon Sep 17 00:00:00 2001
From: Neal Hu <nealhu@apache.org>
Date: Fri, 8 Jun 2018 00:00:29 +0800
Subject: [PATCH] stopRunning in example

---
 .../otter/canal/example/AbstractCanalClientTest.java      | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

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 6b30b98b..33ea6550 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
@@ -96,13 +96,7 @@ public class AbstractCanalClientTest {
         if (!running) {
             return;
         }
-        running = false;
-        if (waiting) {
-            if (connector instanceof ClusterCanalConnector) {
-                ((ClusterCanalConnector) connector).setRetryTimes(-1);
-            }
-            thread.interrupt();
-        }
+        connector.stopRunning();
         if (thread != null) {
             try {
                 thread.join();