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

gbellato
26.31.2007 71ebb3724c79a7d1218c36f080acd6ee162b9cd2
opends/src/server/org/opends/server/replication/server/ReplicationIterator.java
File was renamed from opends/src/server/org/opends/server/replication/server/ChangelogIterator.java
@@ -30,19 +30,19 @@
import org.opends.server.replication.common.ChangeNumber;
import org.opends.server.replication.protocol.UpdateMessage;
import org.opends.server.replication.server.ChangelogDB.ChangelogCursor;
import org.opends.server.replication.server.ReplicationDB.ReplServerDBCursor;
/**
 * This class allows to iterate through the changes received from a given
 * LDAP Server Identifier.
 */
public class ChangelogIterator
public class ReplicationIterator
{
  private UpdateMessage currentChange = null;
  private ChangelogCursor cursor = null;
  private ReplServerDBCursor cursor = null;
  /**
   * Creates a new ChangelogIterator.
   * Creates a new ReplicationIterator.
   * @param id the Identifier of the server on which the iterator applies.
   * @param db The db where the iterator must be created.
   * @param changeNumber The ChangeNumber after which the iterator must start.
@@ -50,8 +50,9 @@
   *         with changeNumber number.
   * @throws DatabaseException if a database problem happened.
   */
  public ChangelogIterator(short id, ChangelogDB db, ChangeNumber changeNumber)
                           throws Exception, DatabaseException
  public ReplicationIterator(
          short id, ReplicationDB db, ChangeNumber changeNumber)
          throws Exception, DatabaseException
  {
    cursor = db.openReadCursor(changeNumber);
    if (cursor == null)
@@ -74,7 +75,7 @@
  }
  /**
   * Go to the next change in the ChangelogDB or in the server Queue.
   * Go to the next change in the ReplicationDB or in the server Queue.
   * @return false if the iterator is already on the last change before
   *         this call.
   */