Collection anyOplans = getBlackboardService().query(new OplanPredicate());
if (myOrganization == null && ! selfOrganizations.isEmpty()) { myOrganization = getMyOrganization(selfOrganizations.elements()); if (myOrganization != null) { clusterId = myOrganization.getClusterPG().getMessageAddress(); } }
  protected void setupSubscriptions() {    oplans = (IncrementalSubscription)getBlackboardService().subscribe(new OplanPredicate());    selfOrganizations = (IncrementalSubscription) getBlackboardService().subscribe(orgsPredicate);    Collection anyOplans = getBlackboardService().query(new OplanPredicate());    if((anyOplans != null) &&       (!(anyOplans.isEmpty())) &&       getBlackboardService().didRehydrate()) {      getLogisticsOPlans();      doUpdateOplans();      publishLogOplanObjects();    }  }