Method disconnectZKInterrupted

test/TestZKClient.java:276–283

()

  }
  
  @Test
  public void disconnectZKInterrupted() throws Exception {
    Mockito.doThrow(new InterruptedException("Interrupted")).when(zk).close();
    zk_client.getDeferredRoot();
    zk_client.disconnectZK();
    verify(zk).close();
    assertNull(Whitebox.getInternalState(zk_client, "zk"));
  }
  
  @Test (expected = RuntimeException.class)
  public void disconnectZKUnexpected() throws Exception {