From 641d37f3cfcb05146cbd99dda0b29ca593601762 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Tue, 10 Mar 2015 16:53:37 +0000 Subject: Refactor use of futures git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1665614 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/test/utils/InternalBrokerHolder.java | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) (limited to 'qpid/java/systests/src') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java index a76f79f8b0..9e8f0d1ca2 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java @@ -21,16 +21,16 @@ package org.apache.qpid.test.utils; import java.security.PrivilegedAction; -import java.util.Map; import java.util.Set; +import javax.security.auth.Subject; + import org.apache.log4j.Logger; import org.apache.qpid.server.Broker; import org.apache.qpid.server.BrokerOptions; import org.apache.qpid.server.security.SecurityManager; - -import javax.security.auth.Subject; +import org.apache.qpid.server.util.Action; public class InternalBrokerHolder implements BrokerHolder { @@ -50,7 +50,14 @@ public class InternalBrokerHolder implements BrokerHolder { LOGGER.info("Starting internal broker (same JVM)"); - _broker = new Broker(); + _broker = new Broker(new Action() + { + @Override + public void performAction(final Integer object) + { + _broker = null; + } + }); _broker.startup(options); } @@ -63,7 +70,10 @@ public class InternalBrokerHolder implements BrokerHolder @Override public Object run() { - _broker.shutdown(); + if(_broker != null) + { + _broker.shutdown(); + } return null; } -- cgit v1.2.1