From 225aaf491fb097f9ab165de1c4d24aaa68670784 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 24 Sep 2013 09:19:20 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/ReplicationServer.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationServer.java b/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
index be985b3..ba9708a 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
@@ -101,7 +101,7 @@
private volatile boolean shutdown = false;
private int rcvWindow;
private int queueSize;
- private final ChangelogDB changelogDB = new JEChangelogDB(this);
+ private final ChangelogDB changelogDB;
/**
* The delay (in sec) after which the changes must be deleted from the
@@ -221,8 +221,8 @@
purgeDelay = configuration.getReplicationPurgeDelay();
rcvWindow = configuration.getWindowSize();
- this.changelogDB.setReplicationDBDirectory(configuration
- .getReplicationDBDirectory());
+ this.changelogDB =
+ new JEChangelogDB(this, configuration.getReplicationDBDirectory());
groupId = (byte)configuration.getGroupId();
weight = configuration.getWeight();
@@ -973,7 +973,7 @@
}
final String newDir = configuration.getReplicationDBDirectory();
- if (newDir != null && !this.changelogDB.getDBDirName().equals(newDir))
+ if (newDir != null && !this.changelogDB.getDBDirectoryName().equals(newDir))
{
return new ConfigChangeResult(ResultCode.SUCCESS, true);
}
@@ -1744,7 +1744,7 @@
*/
public String getDbDirName()
{
- return this.changelogDB.getDBDirName();
+ return this.changelogDB.getDBDirectoryName();
}
/**
--
Gitblit v1.10.0