From 13f31d030c3b205931b63c29b0d6bc1d4eefd163 Mon Sep 17 00:00:00 2001
From: Nicolas Capponi <nicolas.capponi@forgerock.com>
Date: Thu, 21 Aug 2014 13:07:07 +0000
Subject: [PATCH] Checkpoint commit for OPENDJ-1206 : Create a new ReplicationBackend/ChangelogBackend to support cn=changelog CR-4083
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
index 5b3cca6..2706782 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
@@ -712,11 +712,22 @@
public MultiDomainDBCursor getCursorFrom(final MultiDomainServerState startState,
final PositionStrategy positionStrategy) throws ChangelogException
{
+ final Set<DN> excludedDomainDns = Collections.emptySet();
+ return getCursorFrom(startState, positionStrategy, excludedDomainDns);
+ }
+
+ /** {@inheritDoc} */
+ @Override
+ public MultiDomainDBCursor getCursorFrom(final MultiDomainServerState startState,
+ final PositionStrategy positionStrategy, final Set<DN> excludedDomainDns) throws ChangelogException
+ {
final MultiDomainDBCursor cursor = new MultiDomainDBCursor(this, positionStrategy);
registeredMultiDomainCursors.add(cursor);
for (DN baseDN : domainToReplicaDBs.keySet())
{
- cursor.addDomain(baseDN, startState.getServerState(baseDN));
+ if (!excludedDomainDns.contains(baseDN)) {
+ cursor.addDomain(baseDN, startState.getServerState(baseDN));
+ }
}
return cursor;
}
--
Gitblit v1.10.0