}

            @Override
            public ClusterHealthStatus getStatus() {
                return status;
            }

            @Override
            public boolean isTimedOut() {
                return false;
            }

            @Override
            public int getNumberOfNodes() {
                return 3;
            }

            @Override

        final ClusterHealthResponse healthResponse =
                get(c -> c.admin().cluster().prepareHealth(targetIndices).setWaitForYellowStatus().execute());
        if (!healthResponse.isTimedOut()) {
            onConnectListenerList.forEach(l -> {
                try {
                    l.onConnect();
                } catch (final Exception e) {
                    logger.warn("Failed to invoke " + l, e);