ARTEMIS-808 use privileges to stop executor

This commit is contained in:
jbertram 2016-10-18 16:03:59 -05:00 committed by Clebert Suconic
parent 85ce8ccbb7
commit 0df30712b9
1 changed files with 9 additions and 1 deletions

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) {