diff options
Diffstat (limited to 'java/broker/src')
| -rw-r--r-- | java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java b/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java index c70ecf3f91..50f3d711ab 100644 --- a/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java +++ b/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java @@ -41,8 +41,9 @@ public abstract class ApplicationRegistry implements IApplicationRegistry protected final Configuration _configuration; - public static final int DEFAULT_INSTANCE = 0; + public static final int DEFAULT_INSTANCE = 1; public static final String DEFAULT_APPLICATION_REGISTRY = "org.apache.qpid.server.util.NullApplicationRegistry"; + public static String _APPLICATION_REGISTRY = DEFAULT_APPLICATION_REGISTRY; static { @@ -145,8 +146,8 @@ public abstract class ApplicationRegistry implements IApplicationRegistry { try { - _logger.info("Creating DEFAULT_APPLICATION_REGISTRY: " + DEFAULT_APPLICATION_REGISTRY + " : Instance:" + instanceID); - IApplicationRegistry registry = (IApplicationRegistry) Class.forName(DEFAULT_APPLICATION_REGISTRY).getConstructor((Class[]) null).newInstance((Object[]) null); + _logger.info("Creating DEFAULT_APPLICATION_REGISTRY: " + _APPLICATION_REGISTRY + " : Instance:" + instanceID); + IApplicationRegistry registry = (IApplicationRegistry) Class.forName(_APPLICATION_REGISTRY).getConstructor((Class[]) null).newInstance((Object[]) null); ApplicationRegistry.initialise(registry, instanceID); _logger.info("Initialised Application Registry:" + instanceID); return registry; @@ -188,4 +189,9 @@ public abstract class ApplicationRegistry implements IApplicationRegistry } return instance; } + + public static void setDefaultApplicationRegistry(String clazz) + { + _APPLICATION_REGISTRY = clazz; + } } |