synchronized (restartsInProcess) { restartsInProcess.remove(agent); }
restartsInProcess.remove(agent);
  private void restartComplete(MessageAddress agent, MessageAddress dest, int status) {    logger.debug("RestartComplete: agent=" + agent + " dest=" + dest + " status=" + status);    synchronized (listeners) {      for (Iterator it = listeners.iterator(); it.hasNext(); ) {        RestartListener rl = (RestartListener) it.next();        rl.restartComplete(agent.toString(), dest.toString(), status);      }    }    synchronized (restartsInProcess) {      restartsInProcess.remove(agent);    }    restartNext();  }