Repository: activemq Updated Branches: refs/heads/master a9521dceb -> e2b4ca2c5
https://issues.apache.org/jira/browse/AMQ-6108 Update the threads created by the SelectorManager to be daemon threads. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/e2b4ca2c Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/e2b4ca2c Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/e2b4ca2c Branch: refs/heads/master Commit: e2b4ca2c59a316be91cf391c758a10e518dd3a1f Parents: a9521dc Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Mar 15 14:03:12 2016 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Mar 15 14:03:12 2016 -0400 ---------------------------------------------------------------------- .../org/apache/activemq/transport/nio/SelectorManager.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/e2b4ca2c/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java b/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java index 405a208..365500d 100644 --- a/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java +++ b/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java @@ -19,7 +19,12 @@ package org.apache.activemq.transport.nio; import java.io.IOException; import java.nio.channels.spi.AbstractSelectableChannel; import java.util.LinkedList; -import java.util.concurrent.*; +import java.util.concurrent.Executor; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ThreadFactory; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; /** * The SelectorManager will manage one Selector and the thread that checks the @@ -46,7 +51,7 @@ public final class SelectorManager { @Override public Thread newThread(Runnable runnable) { Thread t = new Thread(runnable, "ActiveMQ NIO Worker " + (i++)); - t.setDaemon(false); + t.setDaemon(true); return t; } });
