@Override
public Observable<String> call(Void aVoid) {
    Elasticsearch elasticsearch = vertxContext.verticle().elasticsearch();

    ClusterStateRequestBuilder request =
            elasticsearch.get()
                    .admin()
                    .cluster()
                    .prepareState();
    return elasticsearch.execute(vertxContext, request, elasticsearch.getDefaultAdminTimeout())
            .map(Optional::get)
            .flatMap(clusterStateResponse -> {
                ClusterState state = clusterStateResponse.getState();
                MetaData metadata = state.getMetaData();
                return from(toArray(metadata.getIndices().keysIt(), String.class));
            })
            .filter(s -> s.startsWith(elasticsearch.indexPrefix()));
}
 

protected boolean connect(Collection<InetSocketTransportAddress> addresses, boolean autodiscover) {
    logger.info("trying to connect to {}", addresses);
    client.addTransportAddresses(addresses);
    if (client.connectedNodes() != null) {
        List<DiscoveryNode> nodes = client.connectedNodes();
        if (!nodes.isEmpty()) {
            logger.info("connected to {}", nodes);
            if (autodiscover) {
                logger.info("trying to auto-discover all cluster nodes...");
                ClusterStateRequestBuilder clusterStateRequestBuilder =
                        new ClusterStateRequestBuilder(client, ClusterStateAction.INSTANCE);
                ClusterStateResponse clusterStateResponse = clusterStateRequestBuilder.execute().actionGet();
                DiscoveryNodes discoveryNodes = clusterStateResponse.getState().getNodes();
                client.addDiscoveryNodes(discoveryNodes);
                logger.info("after auto-discovery connected to {}", client.connectedNodes());
            }
            return true;
        }
        return false;
    }
    return false;
}
 

private String getNumberOfReplicas(TransportClient client, String key) {
    ClusterStateRequestBuilder request = client.admin().cluster().prepareState();
    ClusterStateResponse response = request.setIndices(index.getName()).execute().actionGet();
    Settings retrievedSettings = response.getState().getMetaData().index(index.getName()).getSettings();
    String numberOfReplicas = retrievedSettings.get(key);
    return numberOfReplicas;
}
 

private String getNumberOfReplicas(TransportClient client, String key) {
    ClusterStateRequestBuilder request = client.admin().cluster().prepareState();
    ClusterStateResponse response = request.setIndices(index.getName()).execute().actionGet();
    Settings retrievedSettings = response.getState().getMetaData().index(index.getName()).getSettings();
    String numberOfReplicas = retrievedSettings.get(key);
    return numberOfReplicas;
}
 

@Override
public ClusterStateRequestBuilder prepareState() {
    return new ClusterStateRequestBuilder(this, ClusterStateAction.INSTANCE);
}
 

@Override
public ClusterStateRequestBuilder prepareState() {
    return new ClusterStateRequestBuilder(this, ClusterStateAction.INSTANCE);
}
 

/**
 * The state of the cluster.
 */
ClusterStateRequestBuilder prepareState();
 

/**
 * The state of the cluster.
 */
ClusterStateRequestBuilder prepareState();