if (logger.isInfoEnabled()) { logger.info("Reconciled"); } }
  public void restart(final MessageAddress cid) {    if (logger.isInfoEnabled()) {      logger.info(        "Reconcile with "+        (cid==null?"all agents":cid.toString()));    }    UnaryPredicate pred = new UnaryPredicate() {      public boolean execute(Object o) {        if (o instanceof Allocation) {          Allocation alloc = (Allocation) o;          Asset asset = alloc.getAsset();          ClusterPG cpg = asset.getClusterPG();          if (cpg == null) return false;          MessageAddress destination = cpg.getMessageAddress();          return             RestartLogicProviderHelper.matchesRestart(              self, cid, destination);        }        return false;      }    };    Enumeration enum = rootplan.searchBlackboard(pred);    while (enum.hasMoreElements()) {      AllocationforCollections alloc = (AllocationforCollections) enum.nextElement();      UID remoteTaskUID = alloc.getAllocationTaskUID();      Task localTask = alloc.getTask();      if (remoteTaskUID != null && taskShouldBeSent(localTask)) {        Asset asset = alloc.getAsset();        ClusterPG cpg = asset.getClusterPG();        MessageAddress destination = cpg.getMessageAddress();        Task remoteTask = prepareRemoteTask(localTask, destination, remoteTaskUID, false);        if (logger.isInfoEnabled()) {          logger.info(              "Resend" + (cid == null ? "*" : "")              + " task to " + remoteTask.getDestination()              + " with remoteUID=" + remoteTaskUID              + " " + localTask);        }        sendTask(remoteTask, null);      }    }