From 82d1c91b3ffe24136b7ecf1c25df63f97796d3f5 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Tue, 23 Oct 2007 13:36:15 +0000 Subject: [PATCH] Fix for https://issues.apache.org/activemq/browse/AMQ-796 - The threads associated with the session are now setup to be non-daemon so that if you setup a MessageListener and let the main thread exit, your program will not terminate if there are no active transport threads which is the case when the failover transport is in the middle of reconnecting to a broker. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587504 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/activemq/ActiveMQConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java index cb9a892e90..a798e351a2 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java @@ -111,7 +111,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon protected boolean dispatchAsync; protected boolean alwaysSessionAsync = true; - private TaskRunnerFactory sessionTaskRunner = new TaskRunnerFactory("ActiveMQ Session Task", ThreadPriorities.INBOUND_CLIENT_SESSION, true, 1000); + private TaskRunnerFactory sessionTaskRunner = new TaskRunnerFactory("ActiveMQ Session Task", ThreadPriorities.INBOUND_CLIENT_SESSION, false, 1000); private final ThreadPoolExecutor asyncConnectionThread; // Connection state variables