public void monitorSubscription(BasicProcessor bp, IncrementalSubscription subscript){ Vector subscriptions = (Vector)processorSubscriptions_.get(bp); if (subscriptions == null) { subscriptions = new Vector(); processorSubscriptions_.put(bp,subscriptions); } subscriptions.add(subscript);
public void monitorSubscription(BasicProcessor bp, IncrementalSubscription subscript) { Vector subscriptions = (Vector) processorSubscriptions_.get(bp); if (subscriptions == null) { subscriptions = new Vector(); processorSubscriptions_.put(bp, subscriptions);
    public void monitorSubscription(BasicProcessor bp, IncrementalSubscription subscript){	Vector subscriptions = (Vector)processorSubscriptions_.get(bp);	if (subscriptions == null) {	    subscriptions = new Vector();	    processorSubscriptions_.put(bp,subscriptions);	}	subscriptions.add(subscript);    }