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 6a5c6b2d..4df83a90 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 @@ -10,9 +10,10 @@ import com.google.common.base.Joiner; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import javax.management.NotificationBroadcasterSupport; import java.util.Map; -public class CanalServerBean implements CanalServerMXBean { +public class CanalServerBean extends NotificationBroadcasterSupport implements CanalServerMXBean { private static final Logger logger = LoggerFactory.getLogger(CanalServerBean.class);