From 4e76a4bd6e27472e487bc3136de3c3439e949302 Mon Sep 17 00:00:00 2001
From: agapple <jianghang.loujh@alibaba-inc.com>
Date: Fri, 29 Apr 2016 17:43:16 +0800
Subject: [PATCH] fixed issue #176 , handle running deleted

---
 .../otter/canal/client/impl/running/ClientRunningMonitor.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningMonitor.java b/client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningMonitor.java
index a2f13a5f..4c2a9f66 100644
--- a/client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningMonitor.java
+++ b/client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningMonitor.java
@@ -64,6 +64,8 @@ public class ClientRunningMonitor extends AbstractCanalLifeCycle {
             public void handleDataDeleted(String dataPath) throws Exception {
                 MDC.put("destination", destination);
                 mutex.set(false);
+                // 触发一下退出,可能是人为干预的释放操作或者网络闪断引起的session expired timeout
+                processActiveExit();
                 if (!release && activeData != null && isMine(activeData.getAddress())) {
                     // 如果上一次active的状态就是本机，则即时触发一下active抢占
                     initRunning();