class SimpleProcessingItem extends AbstractProcessingItem {

    public void processEvent(ContentEvent event, int counter) {
    	
        int parallelism = this.getParallelism();
        //System.out.println("Process event "+event+" (isLast="+event.isLastEvent()+") with counter="+counter+" while parallelism="+parallelism);
        if (this.arrayProcessingItem == null && parallelism > 0) {
            //Init processing elements, the first time they are needed
            this.arrayProcessingItem = new IProcessingItem[parallelism];
            for (int j = 0; j < parallelism; j++) {
                arrayProcessingItem[j] = this.copy();
                arrayProcessingItem[j].getProcessor().onCreate(j);
            }
        }
        if (this.arrayProcessingItem != null) {
        	IProcessingItem pi = this.getProcessingItem(counter);
        	Processor p = pi.getProcessor();
        	//System.out.println("PI="+pi+", p="+p);
            this.getProcessingItem(counter).getProcessor().process(event);
        }
    }

      SimpleProcessingItem(Processor processor);
      SimpleProcessingItem(Processor processor, int parallelism);

}