Method nullChannel

test/TestRegionClientDecode.java:999–1020

()

  }
  
  @Test
  public void nullChannel() throws Exception {
    // just shows we don't care about the channel either
    final int id = 42;
    final ChannelBuffer buffer = buildGoodResponse(true, id);
    final GetRequest get = new GetRequest(TABLE, ROW);
    final Deferred<Object> deferred = get.getDeferred();
    inflightTheRpc(id, get);
    
    region_client.decode(ctx, null, buffer, VOID);
    @SuppressWarnings("unchecked")
    final List<KeyValue> kvs = (List<KeyValue>)deferred.joinUninterruptibly();
    assertEquals(1, kvs.size());
    assertArrayEquals(ROW, kvs.get(0).key());
    assertArrayEquals(FAMILY, kvs.get(0).family());
    assertArrayEquals(QUALIFIER, kvs.get(0).qualifier());
    assertArrayEquals(VALUE, kvs.get(0).value());
    assertEquals(TIMESTAMP, kvs.get(0).timestamp());
    assertEquals(1, timer.tasks.size());
    assertEquals(60000, (long)timer.tasks.get(0).getValue());
    verify(timer.timeouts.get(0), times(1)).cancel();
  }
  
  @Test (expected = IndexOutOfBoundsException.class)
  public void emptyBuffer() throws Exception {