From 6b9487a0a0ab22e52f2dc193143198d123829311 Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Fri, 12 Jul 2019 09:16:10 +0800
Subject: [PATCH] modify

---
 .../alibaba/otter/canal/deployer/mbean/CanalServerBean.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/mbean/CanalServerBean.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/mbean/CanalServerBean.java
index c08a547b..6a5c6b2d 100644
--- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/mbean/CanalServerBean.java
+++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/mbean/CanalServerBean.java
@@ -77,7 +77,7 @@ public class CanalServerBean implements CanalServerMXBean {
             InstanceAction instanceAction = getInstanceAction(destination);
             if (instanceAction != null) {
                 instanceAction.start(destination);
-
+                return true;
             }
         } catch (Throwable e) {
             logger.error(e.getMessage(), e);
@@ -91,6 +91,7 @@ public class CanalServerBean implements CanalServerMXBean {
             InstanceAction instanceAction = getInstanceAction(destination);
             if (instanceAction != null) {
                 instanceAction.stop(destination);
+                return true;
             }
         } catch (Throwable e) {
             logger.error(e.getMessage(), e);
@@ -104,6 +105,7 @@ public class CanalServerBean implements CanalServerMXBean {
             InstanceAction instanceAction = getInstanceAction(destination);
             if (instanceAction != null) {
                 instanceAction.reload(destination);
+                return true;
             }
         } catch (Throwable e) {
             logger.error(e.getMessage(), e);