(!level2TaskSubscription.getAddedCollection().isEmpty())) { supplyTaskSubscription = (IncrementalSubscription) blackboard. subscribe(new SupplyTaskPredicate(supplyType, taskUtils));
(!level2TaskSubscription.getAddedCollection().isEmpty())) {
  protected void execute() {    //TODO: Remove All Log Oplan references    // get the Logistics OPlan (our homegrown version with specific dates).    if ((logOPlan == null) || logisticsOPlanSubscription.hasChanged()) {      Iterator opIt = logisticsOPlanSubscription.iterator();      if (opIt.hasNext()) {        //we only expect to have one        logOPlan = (LogisticsOPlan) opIt.next();      }    }    if (myOrganization == null) {      myOrganization = getMyOrganization(selfOrganizations.elements());    if (myOrganization != null) {        level2TaskSubscription = (IncrementalSubscription) blackboard.            subscribe(new Level2TaskPredicate(supplyType, taskUtils));        if (logger.isDebugEnabled()) {          logger.debug("Level2TranslatorPlugin just loaded level 2 subscription");        }      } else {        if (logger.isInfoEnabled()) {          logger.info("\n Level2TranslatorPlugin " + supplyType +                      " not ready to process tasks yet." +                      " my org is: " + myOrganization +		       " supply type is " + supplyType);        }        return;    }    }    if ((level2TaskSubscription != null) &&	(!level2TaskSubscription.getAddedCollection().isEmpty())) {      supplyTaskSubscription = (IncrementalSubscription) blackboard.          subscribe(new SupplyTaskPredicate(supplyType, taskUtils));      projectionTaskSubscription = (IncrementalSubscription) blackboard.          subscribe(new ProjectionTaskPredicate(supplyType, taskUtils));      //logger.shout("Level2TranslatorPlugin got Level 2 task - now disposing");      //for now just dispose of them      disposer.disposeAndRemoveExpansion(level2TaskSubscription.getAddedCollection());    }  }