activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-6108
Date Tue, 15 Mar 2016 18:03:30 GMT
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 <tabish121@gmail.com>
Authored: Tue Mar 15 14:03:12 2016 -0400
Committer: Timothy Bish <tabish121@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;
                 }
             });


Mime
View raw message