@Override
    public void failover(NamedNode master) {
        connection.sync(RedisCommands.SENTINEL_FAILOVER, master.getName());
    }
@Test
    public void testFailover() throws InterruptedException {
        Collection<RedisServer> masters = connection.masters();
        connection.failover(masters.iterator().next());
        
        Thread.sleep(10000);
        
        RedisServer newMaster = connection.masters().iterator().next();
        assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
    }