mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

gbellato
16.26.2009 51ef33bebdaa4f8df31131374fce8433c431c298
opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -3061,24 +3061,21 @@
    try
    {
      storeReceivedCTHeartbeat(msg.getChangeNumber());
      // If we are the first replication server warned,
      // then forwards the reset message to the remote replication servers
      for (ReplicationServerHandler rsHandler : replicationServers.values())
      if (senderHandler.isDataServer())
      {
        try
        // If we are the first replication server warned,
        // then forwards the reset message to the remote replication servers
        for (ReplicationServerHandler rsHandler : replicationServers.values())
        {
          // After we'll have sent the message , the remote RS will adopt
          // the new genId
          if (senderHandler.isDataServer())
          try
          {
            rsHandler.send(msg);
          } catch (IOException e)
          {
            TRACER.debugCaught(DebugLogLevel.ERROR, e);
            logError(ERR_CHANGELOG_ERROR_SENDING_MSG.get(rsHandler.getName()));
            stopServer(rsHandler);
          }
        } catch (IOException e)
        {
          TRACER.debugCaught(DebugLogLevel.ERROR, e);
          logError(ERR_CHANGELOG_ERROR_SENDING_MSG.get(rsHandler.getName()));
          stopServer(rsHandler);
        }
      }
    }