diff options
Diffstat (limited to 'qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java')
-rw-r--r-- | qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java index d3e4dfce12..49e5e700c4 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom4To5.java @@ -71,24 +71,16 @@ public class UpgradeFrom4To5 extends AbstractStoreUpgrade private static final String OLD_CONTENT_DB_NAME = "messageContentDb_v4"; private static final String NEW_CONTENT_DB_NAME = "messageContentDb_v5"; - private static final String[] OLD_DATABASE_NAMES = new String[] { EXCHANGE_DB_NAME, OLD_QUEUE_DB_NAME, - OLD_BINDINGS_DB_NAME, OLD_DELIVERY_DB, OLD_METADATA_DB_NAME, OLD_CONTENT_DB_NAME, "bridges_v4", "links_v4", - "xids_v4" }; - private static final String[] NEW_DATABASE_NAMES = new String[] { "exchangeDb_v5", NEW_QUEUE_DB_NAME, - NEW_BINDINGS_DB_NAME, NEW_DELIVERY_DB, NEW_METADATA_DB_NAME, NEW_CONTENT_DB_NAME, "bridges_v5", "links_v5", - "xids_v5" }; - private static final byte COLON = (byte) ':'; private static final Logger _logger = Logger.getLogger(UpgradeFrom4To5.class); - public void performUpgrade(final Environment environment, final UpgradeInteractionHandler handler) throws DatabaseException, AMQStoreException + public void performUpgrade(final Environment environment, final UpgradeInteractionHandler handler, String virtualHostName) throws DatabaseException, AMQStoreException { - _logger.info("Starting store upgrade from version 4"); Transaction transaction = null; try { - reportStarting(environment, OLD_DATABASE_NAMES, USER_FRIENDLY_NAMES); + reportStarting(environment, 4); transaction = environment.beginTransaction(null, null); @@ -103,7 +95,7 @@ public class UpgradeFrom4To5 extends AbstractStoreUpgrade renameRemainingDatabases(environment, handler, transaction); transaction.commit(); - reportFinished(environment, NEW_DATABASE_NAMES, USER_FRIENDLY_NAMES); + reportFinished(environment, 5); } catch (Exception e) |