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