@Test
public void testRequest() throws InterruptedException, IOException {

  bind();
  Map<String, ByteBuffer> flumeMap = new HashMap<>();
  ThriftFlumeEvent thriftEvent =  new ThriftFlumeEvent(
      1, Priority.INFO, ByteBuffer.wrap("foo".getBytes()),
      0, "fooHost", flumeMap);
  FlumeClient fClient = new FlumeClient("0.0.0.0", selectedPort);
  fClient.append(thriftEvent);
  // check if the even has arrived in the channel through OG thrift source
  Transaction transaction = channel.getTransaction();
  transaction.begin();
  Event event = channel.take();
  Assert.assertNotNull(event);
  Assert.assertEquals("Channel contained our event", "foo",
      new String(event.getBody()));
  transaction.commit();
  transaction.close();
  stop();
}