From 793b2352d578039c6070d62fa9f83b4169364694 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 17 Oct 2013 14:27:16 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java | 28 ++++++++++++++++------------
1 files changed, 16 insertions(+), 12 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java b/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java
index 9c0a9be..48c299e 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java
@@ -171,8 +171,9 @@
{
if (isShuttingDown.get())
{
- // TODO JNR i18n
- throw new ChangelogException(Message.raw("DB is closing"));
+ throw new ChangelogException(
+ WARN_CANNOT_OPEN_DATABASE_BECAUSE_SHUTDOWN_WAS_REQUESTED.get(
+ databaseName, replicationServer.getServerId()));
}
final DatabaseConfig dbConfig = new DatabaseConfig();
dbConfig.setAllowCreate(true);
@@ -182,8 +183,9 @@
if (isShuttingDown.get())
{
closeDB(db);
- // TODO JNR i18n
- throw new ChangelogException(Message.raw("DB is closing"));
+ throw new ChangelogException(
+ WARN_CANNOT_OPEN_DATABASE_BECAUSE_SHUTDOWN_WAS_REQUESTED.get(
+ databaseName, replicationServer.getServerId()));
}
allDbs.add(db);
return db;
@@ -437,7 +439,7 @@
}
catch (DatabaseException e)
{
- logError(newErrorMessage(e));
+ logError(newErrorMessage(null, e));
}
}
@@ -450,19 +452,21 @@
}
catch (DatabaseException e)
{
- logError(newErrorMessage(e));
+ logError(newErrorMessage(db.getDatabaseName(), e));
}
}
- private Message newErrorMessage(DatabaseException e)
+ private Message newErrorMessage(String dbName, DatabaseException e)
{
- if (!isShuttingDown.get())
+ final MessageBuilder mb = new MessageBuilder();
+ if (dbName != null)
{
- return NOTE_EXCEPTION_CLOSING_DATABASE
- .get(stackTraceToSingleLineString(e));
+ mb.append(NOTE_EXCEPTION_CLOSING_DATABASE.get(dbName));
}
- MessageBuilder mb = new MessageBuilder();
- mb.append(ERR_ERROR_CLOSING_CHANGELOG_ENV.get());
+ else
+ {
+ mb.append(ERR_ERROR_CLOSING_CHANGELOG_ENV.get());
+ }
mb.append(" ");
mb.append(stackTraceToSingleLineString(e));
return mb.toMessage();
--
Gitblit v1.10.0