diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2006-09-26 08:10:01 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2006-09-26 08:10:01 +0000 |
| commit | fc6e203371b3b60f50a7f045d58fbfb43c081490 (patch) | |
| tree | 9e80eb5ac12c2b35bae228f19cc8332a1e587afa /qpid/java/broker/src | |
| parent | 39112baa4d7fb28c1833bcc663f532841e120080 (diff) | |
| download | qpid-python-fc6e203371b3b60f50a7f045d58fbfb43c081490.tar.gz | |
Changed default instance id to 1 to make getInstance simpler.
Added ability to specify default ApplicationRegistry
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@449942 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src')
| -rw-r--r-- | qpid/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/qpid/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java b/qpid/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java index c70ecf3f91..50f3d711ab 100644 --- a/qpid/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java +++ b/qpid/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; + } } |