OPENDJ-1116 Introduce abstraction for the changelog DB

Jean-Noel Rouvignac

30.29.2013 4772c4aec3a23175ad9ac33b4cd843062168d335

 opends/src/server/org/opends/server/replication/server/changelog/je/DbHandler.java

@@ -43,7 +43,7 @@
import org.opends.server.replication.server.ReplicationServer;
import org.opends.server.replication.server.ReplicationServerDomain;
import org.opends.server.replication.server.changelog.api.ChangelogException;
import org.opends.server.replication.server.changelog.api.ReplicationDBCursor;
import org.opends.server.replication.server.changelog.api.ReplicaDBCursor;
import org.opends.server.replication.server.changelog.je.ReplicationDB.*;
import org.opends.server.types.Attribute;
import org.opends.server.types.Attributes;
@@ -59,7 +59,7 @@
 * server in the topology.
 * It is responsible for efficiently saving the updates that is received from
 * each master server into stable storage.
 * This class is also able to generate a {@link ReplicationDBCursor} that can be
 * This class is also able to generate a {@link ReplicaDBCursor} that can be
 * used to read all changes from a given {@link ChangeNumber}.
 *
 * This class publish some monitoring information below cn=monitor.
@@ -260,26 +260,26 @@
  }

  /**
   * Generate a new {@link ReplicationDBCursor} that allows to browse the db
   * Generate a new {@link ReplicaDBCursor} that allows to browse the db
   * managed by this dbHandler and starting at the position defined by a given
   * changeNumber.
   *
   * @param startAfterCN
   *          The position where the cursor must start.
   * @return a new {@link ReplicationDBCursor} that allows to browse the db
   * @return a new {@link ReplicaDBCursor} that allows to browse the db
   *         managed by this dbHandler and starting at the position defined by a
   *         given changeNumber.
   * @throws ChangelogException
   *           if a database problem happened.
   */
  public ReplicationDBCursor generateCursorFrom(ChangeNumber startAfterCN)
  public ReplicaDBCursor generateCursorFrom(ChangeNumber startAfterCN)
      throws ChangelogException
  {
    if (startAfterCN == null)
    {
      flush();
    }
    return new JEReplicationDBCursor(db, startAfterCN, this);
    return new JEReplicaDBCursor(db, startAfterCN, this);
  }

  /**