}
                client.admin()
                        .cluster()
                        .prepareHealth(actualIndex)
                        .setWaitForYellowStatus()
                        .execute()
                        .actionGet(settings.getClusterTimeout());
            }
            if (empty) {

                        .addAlias(new Alias(getUpdateAlias(index)))
                        .execute()
                        .actionGet(suggestSettings.getIndicesTimeout());

                client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute().actionGet(suggestSettings.getClusterTimeout());
                created = true;
            }
            return created;
        } catch (final Exception e) {

     */
    public void connect() {
        destroy();
        client = createClient();

        final ClusterHealthResponse healthResponse =
                get(c -> c.admin().cluster().prepareHealth(targetIndices).setWaitForYellowStatus().execute());
        if (!healthResponse.isTimedOut()) {
            onConnectListenerList.forEach(l -> {
                try {
                    l.onConnect();