allAssets = new Vector(100,100); pendingAssets = new Vector(100);
c = blackboard.query(new UnaryPredicate() { public boolean execute(Object o) { return (o instanceof AssetChangeEventQueue); } }); if (c.isEmpty()) { if (logger.isDebugEnabled()) logger.debug("AssetChangeEventQueue not found on blackboard."); allEvents = new AssetChangeEventQueue(100,100); blackboard.publishAdd(allEvents); } else { allEvents = (AssetChangeEventQueue)c.iterator().next(); if (logger.isDebugEnabled()) logger.debug("AssetChangeEventQueue found on blackboard = "+allEvents); } pendingEvents = new AssetChangeEventQueue(100);
    public void setupSubscriptions() {	if (blackboard.didRehydrate()) {	    Collection c = blackboard.query(new UnaryPredicate() {		    public boolean execute(Object o) {			return (o instanceof AssetTechSpecTable);		    }		});	    if (c.isEmpty()) {		blackboard.publishAdd(assetTechSpecs);	    } else {		assetTechSpecs = (AssetTechSpecTable)c.iterator().next();	    }	}        allAssets = new Vector(100,100);        pendingAssets = new Vector(100);        communityStatusModelSub =        (IncrementalSubscription)blackboard.subscribe(communityStatusModelPredicate);                        blackboard.publishAdd(this); //publish myself, ONLY after reading in XML    }