private void init(List<GatewayAddress> redisGatewayList) {
        for (GatewayAddress redisGateway : redisGatewayList) {
            final GatewayServer server = new GatewayServer(redisGateway, config.getPoolConfig(),
                    config.getTimeoutMillisec(), config.getKeyspace(), gcp);
            final int count = server.preload(0, config.getConnectPerDelayMillis(), config.getPoolConfig());
            server.setValid(count > 0);

            this.servers.put(redisGateway.getName(), server);
            try {
                this.gcp.addGw(redisGateway.getId(), redisGateway.getHost(), redisGateway.getPort(),
                        config.getPhysicalConnectionCount(), config.getPhysicalConnectionReconnectInterval())
                        .get(config.getTimeoutMillisec(), TimeUnit.MILLISECONDS);
            } catch (InterruptedException e) {
                log.error("[GatewayServer] Failed to connect ", e);
            } catch (ExecutionException e) {
                log.error("[GatewayServer] Failed to connect ", e);
            } catch (TimeoutException e) {
                log.error("[GatewayServer] Failed to connect ", e);
            }
        }
        buildIndex();

        log.info("[Gateway] Initialized " + servers);
    }
private void init(List<GatewayAddress> redisGatewayList) {
        for (GatewayAddress redisGateway : redisGatewayList) {
            final GatewayServer server = new GatewayServer(redisGateway, config.getPoolConfig(),
                    config.getTimeoutMillisec(), config.getKeyspace(), gcp);
            final int count = server.preload(0, config.getConnectPerDelayMillis(), config.getPoolConfig());
            server.setValid(count > 0);

            this.servers.put(redisGateway.getName(), server);
            try {
                this.gcp.addGw(redisGateway.getId(), redisGateway.getHost(), redisGateway.getPort(),
                        config.getPhysicalConnectionCount(), config.getPhysicalConnectionReconnectInterval())
                        .get(config.getTimeoutMillisec(), TimeUnit.MILLISECONDS);
            } catch (InterruptedException e) {
                log.error("[GatewayServer] Failed to connect ", e);
            } catch (ExecutionException e) {
                log.error("[GatewayServer] Failed to connect ", e);
            } catch (TimeoutException e) {
                log.error("[GatewayServer] Failed to connect ", e);
            }
        }
        buildIndex();

        log.info("[Gateway] Initialized " + servers);
    }
private void init ( List < GatewayAddress > redisGatewayList ) { for ( GatewayAddress redisGateway : redisGatewayList ) { final GatewayServer server = new GatewayServer ( redisGateway , config . getPoolConfig ( ) , config . getTimeoutMillisec ( ) , config . getKeyspace ( ) , gcp ) ; final int count = server . preload ( 0 , config . getConnectPerDelayMillis ( ) , config . getPoolConfig ( ) ) ; server . setValid ( count > 0 ) ; this . servers . put ( redisGateway . getName ( ) , server ) ; try { this . gcp . addGw ( redisGateway . getId ( ) , redisGateway . getHost ( ) , redisGateway . getPort ( ) , config . getPhysicalConnectionCount ( ) , config . getPhysicalConnectionReconnectInterval ( ) ) . get ( config . getTimeoutMillisec ( ) , TimeUnit . MILLISECONDS ) ; } catch ( InterruptedException e ) { log . error ( "[GatewayServer] Failed to connect " , e ) ; } catch ( ExecutionException e ) { log . error ( "[GatewayServer] Failed to connect " , e ) ; } catch ( TimeoutException e ) { log . error ( "[GatewayServer] Failed to connect " , e ) ; } } buildIndex ( ) ; log . info ( "[Gateway] Initialized " + servers ) ; }
Inits the.

@param redisGatewayList the redis gateway list
@param addressValidMap
Inits the .