class EventCorrelatingOutputCollector extends OutputCollector {

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

    public  EventCorrelatingOutputCollector(TopologyContext topologyContext, OutputCollector delegate);

}