Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/activemq/browse/AMQ-2486 - systemExitOnShutdown hang 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@835816 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2009-11-13 11:26:16 +00:00
parent 414a6463ef
commit f528aa5b1d
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
View File

@ -31,9 +31,12 @@ import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import org.apache.activemq.ActiveMQConnectionMetaData;
import org.apache.activemq.ConfigurationException;
import org.apache.activemq.Service;
import org.apache.activemq.advisory.AdvisoryBroker;
import org.apache.activemq.broker.cluster.ConnectionSplitBroker;
@ -432,13 +435,9 @@ public class BrokerService implements Service {
return;
}
try {
if (systemExitOnShutdown) {
addShutdownHook(new Runnable() {
public void run() {
Runtime.getRuntime().halt(systemExitOnShutdownExitCode);
}
});
}
if (systemExitOnShutdown && useShutdownHook) {
throw new ConfigurationException("'useShutdownHook' property cannot be be used with 'systemExitOnShutdown', please turn it off (useShutdownHook=false)");
}
processHelperProperties();
if (isUseJmx()) {
startManagementContext();
@ -502,6 +501,15 @@ public class BrokerService implements Service {
if (!started.compareAndSet(true, false)) {
return;
}
if (systemExitOnShutdown) {
new Thread() {
public void run() {
System.exit(systemExitOnShutdownExitCode);
}
}.start();
}
LOG.info("ActiveMQ Message Broker (" + getBrokerName() + ", " + brokerId + ") is shutting down");
removeShutdownHook();
ServiceStopper stopper = new ServiceStopper();
@ -558,6 +566,7 @@ public class BrokerService implements Service {
}
}
}
stopper.throwFirstException();
}