public void awaitConnectionToReplicationCluster() throws InterruptedException {
  replicationClusterConnectedLatch.await();
}

public void awaitConnectionToReplicationCluster ( ) throws InterruptedException { replicationClusterConnectedLatch . await ( ) ; }
wait until we have connected to the cluster .
