From 84cf626ebcae1b535abe9efd3eed5cdf78bdd319 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 05 Sep 2013 07:51:54 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbIterator.java | 29 +++--------------------------
1 files changed, 3 insertions(+), 26 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbIterator.java b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbIterator.java
index 18ecd5d..762d027 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbIterator.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbIterator.java
@@ -29,7 +29,6 @@
import org.opends.messages.Message;
import org.opends.server.loggers.debug.DebugTracer;
-import org.opends.server.replication.common.CSN;
import org.opends.server.replication.server.changelog.api.*;
import org.opends.server.replication.server.changelog.je.DraftCNDB.*;
import org.opends.server.types.DebugLogLevel;
@@ -68,13 +67,13 @@
/** {@inheritDoc} */
@Override
- public String getBaseDN()
+ public CNIndexData getCNIndexData()
{
try
{
- return this.draftCNDbCursor.currentBaseDN();
+ return this.draftCNDbCursor.currentData();
}
- catch(Exception e)
+ catch (Exception e)
{
TRACER.debugCaught(DebugLogLevel.ERROR, e);
return null;
@@ -83,28 +82,6 @@
/** {@inheritDoc} */
@Override
- public CSN getCSN()
- {
- try
- {
- return this.draftCNDbCursor.currentCSN();
- }
- catch(Exception e)
- {
- TRACER.debugCaught(DebugLogLevel.ERROR, e);
- return null;
- }
- }
-
- /** {@inheritDoc} */
- @Override
- public long getChangeNumber()
- {
- return ((ReplicationDraftCNKey) draftCNDbCursor.getKey()).getChangeNumber();
- }
-
- /** {@inheritDoc} */
- @Override
public boolean next() throws ChangelogException
{
if (draftCNDbCursor != null)
--
Gitblit v1.10.0