class EventCorrelatingOutputCollector extends OutputCollector {

    @Override
    public void fail(Tuple tuple) {
        delegate.fail(tuple);
    }

    public  EventCorrelatingOutputCollector(TopologyContext topologyContext, OutputCollector delegate);

}