From 4fed0daa395855cd567621b0b38d405c9af254f4 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 26 Sep 2013 15:29:01 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java | 12 ++++--------
1 files changed, 4 insertions(+), 8 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java b/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java
index f06a43d..7b98f6b 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java
@@ -27,7 +27,6 @@
*/
package org.opends.server.replication.server.changelog.je;
-import org.opends.messages.Message;
import org.opends.server.replication.common.CSN;
import org.opends.server.replication.protocol.UpdateMsg;
import org.opends.server.replication.server.changelog.api.ChangelogException;
@@ -39,8 +38,8 @@
*/
public class JEReplicaDBCursor implements ReplicaDBCursor
{
- private UpdateMsg currentChange = null;
- private ReplServerDBCursor cursor = null;
+ private UpdateMsg currentChange;
+ private ReplServerDBCursor cursor;
private DbHandler dbHandler;
private ReplicationDB db;
private CSN lastNonNullCurrentCSN;
@@ -52,7 +51,8 @@
* @param db
* The db where the cursor must be created.
* @param startAfterCSN
- * The CSN after which the cursor must start.
+ * The CSN after which the cursor must start.If null, start from the
+ * oldest CSN
* @param dbHandler
* The associated DbHandler.
* @throws ChangelogException
@@ -82,10 +82,6 @@
// look again in the db
cursor = db.openReadCursor(startAfterCSN);
- if (cursor == null)
- {
- throw new ChangelogException(Message.raw("no new change"));
- }
}
}
--
Gitblit v1.10.0