@Test
public void testCollectorSource() throws FlumeSpecException, IOException,
    InterruptedException {

  EventSource src = FlumeBuilder.buildSource(LogicalNodeContext
      .testingContext(), "collectorSource(34568)");
  EventSink snk = FlumeBuilder.buildSink(new Context(),
      "rpcSink(\"localhost\", 34568)");
  src.open();
  snk.open();
  snk.append(new EventImpl("foo".getBytes()));
  src.next();
  snk.close();
  src.close();
}