}
  private void removeExpiredRestarts() {      long now = now();      for (Iterator it = restartsInProcess.entrySet().iterator(); it.hasNext();) {        Map.Entry me = (Map.Entry)it.next();        MessageAddress agent = (MessageAddress)me.getKey();        long expiration = ((Long)me.getValue()).longValue();        if (expiration < now) {          it.remove();          logger.debug("Restart timeout: agent=" + agent);          restartComplete(agent, agentId, FAIL);        }      }  }