registry.register("messageChange",
dataRefresh,
rebalancePipeline);
registry.register("externalView", dataRefresh);
registry.register("resume", dataRefresh, rebalancePipeline, externalViewPipeline);
registry.register("periodicalRebalance", dataRefresh, rebalancePipeline, externalViewPipeline);
// health stats pipeline
// Pipeline healthStatsAggregationPipeline = new Pipeline();
// StatsAggregationStage statsStage = new StatsAggregationStage();
// healthStatsAggregationPipeline.addStage(new ReadHealthDataStage());