if (CHECKALLOC) { if (logplan.findTask(task) == null) {   if (logger.isInfoEnabled()) logger.info(self + ": RemoteAllocationLP: Allocation of rescinded Task: " + task + " using new Allocation " + all); return; } }
  private void examine(Object obj, Collection changes) {    if (! (obj instanceof Allocation)) return;    AllocationforCollections all = (AllocationforCollections) obj;    Task task = all.getTask();    Asset asset = all.getAsset();    ClusterPG cpg = asset.getClusterPG();    if (cpg == null) return;    MessageAddress destination = cpg.getMessageAddress();    if (destination == null) return;    if (!taskShouldBeSent(task)) {      if (logger.isDebugEnabled()) {        logger.debug("shouldNotBeSent: " + task);      }      return; // In past    }    // see if we're reissuing the task... if so, we'll just use it.    UID copyUID = all.getAllocationTaskUID();    boolean isDeleted = all.isAllocationTaskDeleted();    Task copytask = prepareRemoteTask(task, destination, copyUID, isDeleted);    ((AllocationforCollections)all).setAllocationTask(copytask);    rootplan.change(all, changes);     // Give the task directive to the blackboard for transmission    sendTask(copytask, changes);  }