@Test
public void testFail() throws Exception {

    setupExpectationsForTuple();
    setupExpectationsForTopologyContextNoEmit();
    EventCorrelatingOutputCollector sut = getSystemUnderTest();
    Tuple anchor = new TupleImpl(mockedTopologyContext, new Values(PARENT_STREAMLINE_EVENT), TASK_0,
            Utils.DEFAULT_STREAM_ID);
    sut.fail(anchor);
    new Verifications() {{
        mockedOutputCollector.fail(anchor); times = 1;
    }};
}