class StormProcessingItem extends AbstractProcessingItem implements StormTopologyNode {

	@Override
	public void addToTopology(StormTopology topology, int parallelismHint) {
		if(piBoltDeclarer != null){
			//throw exception that one PI only belong to one topology
		}else{		
			TopologyBuilder stormBuilder = topology.getStormBuilder();
			this.piBoltDeclarer = stormBuilder.setBolt(this.getName(), 
					this.piBolt, parallelismHint);
		}	
	}

	  StormProcessingItem(Processor processor, int parallelismHint);
	  StormProcessingItem(Processor processor, String friendlyId, int parallelismHint);

}