summaryrefslogtreecommitdiff
path: root/java/broker/src/main
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2010-06-02 16:43:12 +0000
committerMartin Ritchie <ritchiem@apache.org>2010-06-02 16:43:12 +0000
commita4d092cfad2d9ee46522d737bdcdd35f3ce74f44 (patch)
treeebc3ee7f18aff6d698ff75999f53ce4da3da7d88 /java/broker/src/main
parenta489a9d3def2adaa587e887cd6468cc500f152e2 (diff)
downloadqpid-python-a4d092cfad2d9ee46522d737bdcdd35f3ce74f44.tar.gz
QPID-2632 : Remove NullApplicationRegistry
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@950642 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/main')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java22
1 files changed, 1 insertions, 21 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java
index 9adab58a0c..2164ef1b30 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java
@@ -72,8 +72,6 @@ public abstract class ApplicationRegistry implements IApplicationRegistry
protected final ServerConfiguration _configuration;
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;
protected final Map<InetSocketAddress, QpidAcceptor> _acceptors = new HashMap<InetSocketAddress, QpidAcceptor>();
@@ -315,20 +313,7 @@ public abstract class ApplicationRegistry implements IApplicationRegistry
if (instance == null)
{
- try
- {
- _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;
- }
- catch (Exception e)
- {
- _logger.error("Error configuring application: " + e, e);
- //throw new AMQBrokerCreationException(instanceID, "Unable to create Application Registry instance " + instanceID);
- throw new RuntimeException("Unable to create Application Registry", e);
- }
+ throw new IllegalStateException("Application Registry (" + instanceID + ") not created");
}
else
{
@@ -420,11 +405,6 @@ public abstract class ApplicationRegistry implements IApplicationRegistry
}
}
- public static void setDefaultApplicationRegistry(String clazz)
- {
- _APPLICATION_REGISTRY = clazz;
- }
-
public VirtualHostRegistry getVirtualHostRegistry()
{
return _virtualHostRegistry;