OPENDJ-1116 Introduce abstraction for the changelog DB

Jean-Noel Rouvignac

10.32.2013 b4a1565a2ab3cd0192a1b17c026f16e151fd04ca

 opends/src/server/org/opends/server/replication/server/MessageHandler.java

@@ -41,7 +41,7 @@
import org.opends.server.replication.common.ServerState;
import org.opends.server.replication.protocol.UpdateMsg;
import org.opends.server.replication.server.changelog.api.ChangelogException;
import org.opends.server.replication.server.changelog.api.ReplicaDBCursor;
import org.opends.server.replication.server.changelog.api.DBCursor;
import org.opends.server.types.*;

import static org.opends.messages.ReplicationMessages.*;
@@ -296,14 +296,14 @@
           *           restart as usual
           *   load this change on the delayList
           */
          ReplicaDBCursor cursor = null;
          DBCursor<UpdateMsg> cursor = null;
          try
          {
            // fill the lateQueue
            cursor = replicationServerDomain.getCursorFrom(serverState);
            while (cursor.next() && isLateQueueBelowThreshold())
            {
              lateQueue.add(cursor.getChange());
              lateQueue.add(cursor.getRecord());
            }
          }
          catch (ChangelogException e)
@@ -454,12 +454,12 @@

  private CSN findOldestCSNFromReplicaDBs()
  {
    ReplicaDBCursor cursor = null;
    DBCursor<UpdateMsg> cursor = null;
    try
    {
      cursor = replicationServerDomain.getCursorFrom(serverState);
      cursor.next();
      return cursor.getChange().getCSN();
      return cursor.getRecord().getCSN();
    }
    catch (Exception e)
    {