if ((myOrgActivitySubscription != null) && (myOrgActivitySubscription.hasChanged())) { processPotentialChangedOpCons(); }  if (myOpConInfoRelaySubscription.hasChanged()) { if (myLogger.isInfoEnabled()) { myLogger.info(getAgentIdentifier() +" myOpConInfoRelaySubscription has changed!"); } Collection changedOpConInfoRelays = myOpConInfoRelaySubscription.getChangedCollection();  createOperationalRFDs(changedOpConInfoRelays); } }
  public void execute() {    if (oplans.hasChanged()) {      Enumeration enum;      if (oplans.getAddedList().hasMoreElements()) {        enum = oplans.getAddedList();        while (enum.hasMoreElements()) {          Oplan oplan = (Oplan)enum.nextElement();          UID oplanUID = oplan.getUID();          if (orgActivities == null) {            orgActivities = (IncrementalSubscription)              getBlackboardService().subscribe(new OrgActivitiesPredicate(oplanUID));          }        }      }    }