diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-08-06 09:40:25 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-08-06 09:40:25 +0000 |
| commit | 5790989fd05cc3694fab20804f719f38093dfd55 (patch) | |
| tree | 9ff99d45510acea33a5cd7d21ddff88896957d37 /qpid/java/broker/src/main | |
| parent | 7697d047267d136b1c9666232920248969096a56 (diff) | |
| download | qpid-python-5790989fd05cc3694fab20804f719f38093dfd55.tar.gz | |
QPID-2002 : Updates to Test ARs to correctly remove the CurrentActor on close. Update to CFAR to ensure that an Actor is set during shutdown. Update to TestLogActor's log Name and corrected CurrentActorTest's testname.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801573 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/main')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java | 17 |
1 files changed, 16 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java index 043c048f51..25202460c0 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java @@ -71,10 +71,25 @@ public class ConfigurationFileApplicationRegistry extends ApplicationRegistry initialiseVirtualHosts(); - // Startup complete pop the current actor + // Startup complete pop the current actor CurrentActor.remove(); } + @Override + public void close() throws Exception + { + //Set the Actor for Broker Shutdown + CurrentActor.set(new BrokerActor(_rootMessageLogger)); + try + { + super.close(); + } + finally + { + CurrentActor.remove(); + } + } + private void initialiseVirtualHosts() throws Exception { for (String name : _configuration.getVirtualHosts()) |
