code: private void ready() {
      try {
        ready.await();
      } catch (InterruptedException ex) {
        log.error("Connect call was inturrupted", ex);
        Thread.currentThread().interrupt();
      }
    }
docs: Make sure hankshake/connect is set.