});
} int waited = 0; while (c.isEmpty()) { try { logger.error("starting to sleep for oplan objects at "+waited+" seconds at "+clusterId); Thread.currentThread().sleep(3000); waited=waited+3; } catch (Exception ex) { logger.error("Exception sleeping for OPlan "+ex); ex.printStackTrace(); } c = getBlackboardService().query(logisticsOPlanPredicate); } logger.debug("Got the OPlan at "+clusterId);
  private void getLogisticsOPlans() {    Collection c = getBlackboardService().query(new UnaryPredicate() {      public boolean execute(Object o) {	return o instanceof LogisticsOPlan;      }    });    for (Iterator i = c.iterator(); i.hasNext(); ) {      LogisticsOPlan loplan = (LogisticsOPlan) i.next();      oplanHash.put(loplan.getOplanUID(), loplan);            UID oplanUID = loplan.getOplanUID();      IncrementalSubscription oplanActivities = (IncrementalSubscription)	orgActivitySubscriptionOfOPlanUID.get(oplanUID);      if (oplanActivities == null) {	oplanActivities = (IncrementalSubscription)	  getBlackboardService().subscribe(new OplanOrgActivitiesPredicate(oplanUID));	orgActivitySubscriptionOfOPlanUID.put(oplanUID, oplanActivities);      }    }  }