ClusterOPlan coplan = (ClusterOPlan) i.next(); ClusterOPlans_.put(coplan.getOplanUID(), coplan);
ClusterOPlan coplan = (ClusterOPlan) i.next(); UID oplanUID = coplan.getOplanUID(); ClusterOPlans_.put(oplanUID, coplan); IncrementalSubscription oplanActivities = (IncrementalSubscription) orgActivitySubscriptionOfOPlanUID.get(oplanUID); if (oplanActivities == null) { oplanActivities = (IncrementalSubscription) subscribe(new OplanOrgActivitiesPredicate(oplanUID)); monitorPlugInSubscription(oplanActivities); orgActivitySubscriptionOfOPlanUID.put(oplanUID, oplanActivities); }
    private void getClusterOPlans() {        Collection c = query(new UnaryPredicate() {            public boolean execute(Object o) {                return o instanceof ClusterOPlan;            }        });        for (Iterator i = c.iterator(); i.hasNext(); ) {            ClusterOPlan coplan = (ClusterOPlan) i.next();            ClusterOPlans_.put(coplan.getOplanUID(), coplan);        }    }