subscribe(new SupplyTaskPredicate(supplyType, taskUtils));
subscribe(new SupplyTaskPredicate(supplyType, getOrgName(),taskUtils));
  protected void execute() {    if (myOrganization == null) {      myOrganization = getMyOrganization(selfOrganizations.elements());      if (myOrganization != null) {        level2TaskSubscription = (IncrementalSubscription) blackboard.            subscribe(new Level2TaskPredicate(supplyType, taskUtils));        supplyTaskSubscription = (IncrementalSubscription) blackboard.            subscribe(new SupplyTaskPredicate(supplyType, taskUtils));        projectionTaskSubscription = (IncrementalSubscription) blackboard.            subscribe(new ProjectionTaskPredicate(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())) {      if (doTranslate) {        translateTasks(level2TaskSubscription.getAddedCollection(),                       projectionTaskSubscription.getCollection(),                       supplyTaskSubscription.getCollection());      } else {        //logger.shout("Level2TranslatorPlugin got Level 2 task - now disposing");        disposer.disposeAndRemoveExpansion(level2TaskSubscription.getAddedCollection());      }    } else if ((level2TaskSubscription != null) &&        ((level2TaskSubscription.hasChanged()) ||        (projectionTaskSubscription.hasChanged()) ||        (supplyTaskSubscription.hasChanged()))) {      if (doTranslate) {        translateTasks(level2TaskSubscription.getCollection(),                       projectionTaskSubscription.getCollection(),                       supplyTaskSubscription.getCollection());      }    }  }