Method callbackException

test/TestHBaseRpc.java:214–229

()

  }
  
  @Test
  public void callbackException() throws Exception {
    final GetRequest rpc = new GetRequest(TABLE, KEY, FAMILY);
    rpc.attempt = 4;
    final Deferred<Object> deferred = rpc.getDeferred();
    assertEquals(4, rpc.attempt);
    assertNull(rpc.timeout_handle);
    assertTrue(rpc.hasDeferred());
    
    rpc.callback(new NonRecoverableException("Boo!"));
    try {
      deferred.join();
    } catch (NonRecoverableException e) { }
    assertEquals(0, rpc.attempt);
    assertFalse(rpc.hasDeferred());
  }
  
  @Test
  public void callbackWithTimeout() throws Exception {