class EventCorrelatingOutputCollector extends OutputCollector {

    @Override
    public void reportError(Throwable throwable) {
        delegate.reportError(throwable);
    }

    public  EventCorrelatingOutputCollector(TopologyContext topologyContext, OutputCollector delegate);

}