class EventCorrelatingSpoutOutputCollector extends SpoutOutputCollector {

    @Override
    public long getPendingCount() {
        return delegate.getPendingCount();
    }

    public  EventCorrelatingSpoutOutputCollector(TopologyContext topologyContext, SpoutOutputCollector delegate);

}