From f95eca255b79a070abb510da157a37969c81fed2 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 01 Oct 2013 07:38:46 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java
index 83b9c03..793773b 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java
@@ -58,6 +58,7 @@
import org.opends.server.replication.protocol.ReplicationMsg;
import org.opends.server.replication.protocol.Session;
import org.opends.server.replication.server.ReplicationServer;
+import org.opends.server.replication.server.changelog.je.JEChangelogDB;
import org.opends.server.replication.service.ReplicationBroker;
import org.opends.server.replication.service.ReplicationDomain;
import org.opends.server.schema.DirectoryStringSyntax;
@@ -463,14 +464,18 @@
assertEquals(DirectoryServer.getBackend("replicationChanges"), null, "Replication changes backend object has been left");
}
+ protected void clearChangelogDB(ReplicationServer rs)
+ {
+ ((JEChangelogDB) rs.getChangelogDB()).clearDB();
+ }
+
/**
* Cleanup databases of the currently instantiated replication servers in the
* VM
*/
protected void cleanUpReplicationServersDB() {
-
for (ReplicationServer rs : ReplicationServer.getAllInstances()) {
- rs.clearDb();
+ clearChangelogDB(rs);
}
}
@@ -480,6 +485,7 @@
*/
protected void removeReplicationServerDB() {
for (ReplicationServer rs : ReplicationServer.getAllInstances()) {
+ clearChangelogDB(rs);
rs.removeDb();
}
}
--
Gitblit v1.10.0