summaryrefslogtreecommitdiff
path: root/qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java')
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java10
1 files changed, 8 insertions, 2 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java
index 124584e99c..1cadf270d7 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/configuration/startup/StoreUpgrader.java
@@ -1,4 +1,4 @@
-package org.apache.qpid.server.configuration.startup;/*
+/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
@@ -19,10 +19,13 @@ package org.apache.qpid.server.configuration.startup;/*
*
*/
+package org.apache.qpid.server.configuration.startup;
+
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
+
import org.apache.qpid.server.configuration.ConfigurationEntry;
import org.apache.qpid.server.configuration.ConfigurationEntryStore;
import org.apache.qpid.server.model.Broker;
@@ -30,6 +33,7 @@ import org.apache.qpid.server.model.Broker;
public abstract class StoreUpgrader
{
+
private static Map<String, StoreUpgrader> _upgraders = new HashMap<String, StoreUpgrader>();
// Note: don't use externally defined constants in upgraders in case they change, the values here MUST stay the same
@@ -134,7 +138,9 @@ public abstract class StoreUpgrader
}
};
- private StoreUpgrader(String version)
+ final static StoreUpgrader UPGRADE_1_3 = new StoreUpgrader1_3("1.3");
+
+ protected StoreUpgrader(String version)
{
_upgraders.put(version, this);
}