Method getRequest

test/TestRegionClientSendRpc.java:243–257

()

  }
  
  @Test
  public void getRequest() throws Exception {    
    final GetRequest get = new GetRequest(TABLE, KEY, FAMILY, QUALIFIER);
    get.setRegion(region);
    get.getDeferred(); // required to initialize the deferred
    
    region_client.sendRpc(get);
    
    PowerMockito.verifyStatic(times(1));
    Channels.write((Channel)any(), (ChannelBuffer)any());
    verify(hbase_client, never()).sendRpcToRegion(get);
    assertEquals(1, region_client.stats().rpcsSent());
    assertEquals(0, region_client.stats().pendingBatchedRPCs());
    assertEquals(0, region_client.stats().pendingRPCs());
  }

  @Test
  public void getRequestNoTimeout() throws Exception {