OPENDJ-1705 File based changelog: handle concurrency between purge and cursors

Nicolas Capponi

11.53.2015 b877a7554a1fa1c47a2982541972efe780dfad9a

 opendj-server-legacy/src/main/java/org/opends/server/replication/server/ServerHandler.java

@@ -46,6 +46,7 @@
import org.opends.server.replication.common.RSInfo;
import org.opends.server.replication.common.ServerStatus;
import org.opends.server.replication.protocol.*;
import org.opends.server.replication.server.changelog.api.ChangelogException;
import org.opends.server.types.Attribute;
import org.opends.server.types.Attributes;
import org.opends.server.types.DirectoryException;
@@ -925,8 +926,10 @@
   *
   * @return the next update that must be sent to the server managed by this
   *         ServerHandler.
   * @throws ChangelogException
   *            If a problem occurs when reading the changelog
   */
  public UpdateMsg take()
  public UpdateMsg take() throws ChangelogException
  {
    final UpdateMsg msg = getNextMessage(serverId);