class EventCorrelatingSpoutOutputCollector extends SpoutOutputCollector {

    @Override
    public List<Integer> emit(String streamId, List<Object> tuple) {
        StreamlineEvent newEvent = injectCorrelationInformation(tuple);
        return delegate.emit(streamId, new Values(newEvent));
    }

    public  EventCorrelatingSpoutOutputCollector(TopologyContext topologyContext, SpoutOutputCollector delegate);

}