logger.debug("Got the OPlan at "+clusterId);
if (logger.isDebugEnabled()) { logger.debug("Got the OPlan at "+clusterId); }
  private void getLogisticsOPlans() {    Collection c = getBlackboardService().query(logisticsOPlanPredicate);    if (myOrganization == null) {      myOrganization = getMyOrganization(selfOrganizations.elements());      if (myOrganization != null) {	clusterId = myOrganization.getClusterPG().getClusterIdentifier();      }    }    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);    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);      }    }  }