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

This closes #847

This commit is contained in:
Clebert Suconic 2016-10-18 17:45:33 -04:00
parent 85ce8ccbb7 0df30712b9
commit b1804da00c
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnection.java
View File

@ -33,6 +33,8 @@ import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import java.lang.ref.WeakReference;
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.ExecutorService;
@ -359,7 +361,13 @@ public class ActiveMQConnection extends ActiveMQConnectionForContextImpl impleme
}
}
failoverListenerExecutor.shutdown();
AccessController.doPrivileged(new PrivilegedAction() {
@Override
public Object run() {
failoverListenerExecutor.shutdown();
return null;
}
});
closed = true;
} catch (ActiveMQException e) {