@Test
public void testCustomDataConsumerAccess() {

    DataConsumer dc = new DataConsumer();
    DataPipe thePipe = new DataPipe(dc);
    dc.setReportingHost("localhost:8080");
    dc.setMaxNumberOfLines(100000);
    Assert.assertEquals("localhost:8080", thePipe.getDataConsumer().getReportingHost());
    Assert.assertEquals(100000, thePipe.getDataConsumer().getMaxNumberOfLines());
}