DefaultSentinelManager implements SentinelManager { @Override public void removeSentinelMonitor(Sentinel sentinel, String sentinelMonitorName) { SimpleObjectPool<NettyClient> clientPool = keyedClientPool .getKeyPool(new DefaultEndPoint(sentinel.getIp(), sentinel.getPort())); AbstractSentinelCommand.SentinelRemove sentinelRemove = new AbstractSentinelCommand .SentinelRemove(clientPool, sentinelMonitorName, scheduled); silentCommand(sentinelRemove); try { String result = sentinelRemove.execute().get(); logger.info("[removeSentinels]removeSentinelMonitor {} from {} : {}", sentinelMonitorName, sentinel, result); } catch (Exception e) { logger.error("removeSentinelMonitor {} from {} : {}", sentinelMonitorName, sentinel, e.getMessage()); } }  @Override void removeShardSentinelMonitors(ShardEvent shardEvent); @Override HostPort getMasterOfMonitor(Sentinel sentinel, String sentinelMonitorName); @Override void removeSentinelMonitor(Sentinel sentinel, String sentinelMonitorName); @Override String infoSentinel(Sentinel sentinel); @Override void monitorMaster(Sentinel sentinel, String sentinelMonitorName, HostPort master, int quorum); @Override List<HostPort> slaves(Sentinel sentinel, String sentinelMonitorName); @Override void reset(Sentinel sentinel, String sentinelMonitorName); @VisibleForTesting DefaultSentinelManager setScheduled(ScheduledExecutorService scheduled); @VisibleForTesting DefaultSentinelManager setKeyedClientPool(XpipeNettyClientKeyedObjectPool keyedClientPool);  }
@Test public void removeSentinel() throws Exception { manager.removeSentinelMonitor(new Sentinel("b99ecc0cc2194c349c61bc2e95b59b9cb07250da", "127.0.0.1", port), "test"); }