@Test
public void testStreamBuilder() throws IOException, FlumeSpecException {

  ExecNioSource e = (ExecNioSource) ExecNioSource.buildStream().build(
      "ps -aux");
  assertEquals(e.inAggregateMode, false);
  assertEquals(e.command, "ps -aux");
  assertEquals(e.restart, false);
  assertEquals(e.period, 0);
}