Repository: helix Updated Branches: refs/heads/master f1ffa8619 -> 560097fbe
[HELIX-382] GenericHelixController now implements InstanceConfigChangeListener, ConfigChangeListener delegates call to InstanceConfigChangeListener Project: http://git-wip-us.apache.org/repos/asf/helix/repo Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/560097fb Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/560097fb Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/560097fb Branch: refs/heads/master Commit: 560097fbebb02096018614bbc8a09430d5a4bb4f Parents: f1ffa86 Author: Kanak Biscuitwala <[email protected]> Authored: Sun Feb 16 11:32:34 2014 -0800 Committer: Kanak Biscuitwala <[email protected]> Committed: Sun Feb 16 11:34:51 2014 -0800 ---------------------------------------------------------------------- .../apache/helix/controller/GenericHelixController.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/helix/blob/560097fb/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java ---------------------------------------------------------------------- diff --git a/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java b/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java index e9924a2..2b2a71e 100644 --- a/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java +++ b/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java @@ -37,6 +37,7 @@ import org.apache.helix.HealthStateChangeListener; import org.apache.helix.HelixDataAccessor; import org.apache.helix.HelixManager; import org.apache.helix.IdealStateChangeListener; +import org.apache.helix.InstanceConfigChangeListener; import org.apache.helix.LiveInstanceChangeListener; import org.apache.helix.MessageListener; import org.apache.helix.NotificationContext; @@ -88,7 +89,8 @@ import org.apache.log4j.Logger; */ public class GenericHelixController implements ConfigChangeListener, IdealStateChangeListener, LiveInstanceChangeListener, MessageListener, CurrentStateChangeListener, - ExternalViewChangeListener, ControllerChangeListener, HealthStateChangeListener { + ExternalViewChangeListener, ControllerChangeListener, HealthStateChangeListener, + InstanceConfigChangeListener{ private static final Logger logger = Logger.getLogger(GenericHelixController.class.getName()); volatile boolean init = false; private final PipelineRegistry _registry; @@ -426,6 +428,14 @@ public class GenericHelixController implements ConfigChangeListener, IdealStateC } @Override + public void onInstanceConfigChange(List<InstanceConfig> instanceConfigs, + NotificationContext changeContext){ + logger.info("START: GenericClusterController.onInstanceConfigChange()"); + onConfigChange(instanceConfigs, changeContext); + logger.info("END: GenericClusterController.onInstanceConfigChange()"); + } + + @Override public void onControllerChange(NotificationContext changeContext) { logger.info("START: GenericClusterController.onControllerChange()"); if (changeContext != null && changeContext.getType() == Type.FINALIZE) {
