SentinelHelloCheckAction extends AbstractLeaderAwareHealthCheckAction { @VisibleForTesting protected void processSentinelHellos() { getActionInstance().getRedisSession().closeSubscribedChannel(HELLO_CHANNEL); SentinelActionContext actionContext = null != subError ? new SentinelActionContext(getActionInstance(), subError) : new SentinelActionContext(getActionInstance(), hellos); notifyListeners(actionContext); hellos = Sets.newConcurrentHashSet(); } SentinelHelloCheckAction(ScheduledExecutorService scheduled, RedisHealthCheckInstance instance,
                                    ExecutorService executors, ConsoleDbConfig consoleDbConfig, ClusterService clusterService);  static final String HELLO_CHANNEL; }
@Test public void testProcessSentinelHellos() { }