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);