+
+ public void waitTillReady(){
+ LOG.info("Beginning to wait for data store to become ready : {}", type);
+
+ try {
+ waitTillReadyCountDownLatch.await(waitTillReadyTimeInMillis, TimeUnit.MILLISECONDS);
+
+ LOG.debug("Data store {} is now ready", type);
+ } catch (InterruptedException e) {
+ LOG.error("Interrupted when trying to wait for shards to become leader in a reasonable amount of time - giving up");
+ }
+ }
+
+ @VisibleForTesting
+ public CountDownLatch getWaitTillReadyCountDownLatch() {
+ return waitTillReadyCountDownLatch;
+ }