Method getMockHBaseRpc

test/BaseTestHBaseClient.java:400–417

Generate and return a mocked HBase RPC for testing purposes with a valid Deferred that can be called on execution. @param deferred A deferred to watch for results @return The RPC to pass through unit tests.

(final Deferred<Object> deferred)

   * @return The RPC to pass through unit tests.
   */
  protected HBaseRpc getMockHBaseRpc(final Deferred<Object> deferred) {
    final HBaseRpc rpc = mock(HBaseRpc.class);
    rpc.attempt = 0;
    when(rpc.getDeferred()).thenReturn(deferred);
    when(rpc.toString()).thenReturn("MockRPC");
    PowerMockito.doAnswer(new Answer<Void>() {
      @Override
      public Void answer(InvocationOnMock invocation) throws Throwable {
        if (deferred != null) {
          deferred.callback(invocation.getArguments()[0]);
        } else {
          System.out.println("Deferred was null!!");
        }
        return null;
      }
    }).when(rpc).callback(Object.class);
    return rpc;
  }
}