OPENDJ-1116 Introduce abstraction for the changelog DB

Jean-Noel Rouvignac

17.27.2013 793b2352d578039c6070d62fa9f83b4169364694

 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();