mirror of https://github.com/apache/activemq.git
- 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
This commit is contained in:
parent
569e5ca78c
commit
82d1c91b3f
|
@ -111,7 +111,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
|
||||||
protected boolean dispatchAsync;
|
protected boolean dispatchAsync;
|
||||||
protected boolean alwaysSessionAsync = true;
|
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;
|
private final ThreadPoolExecutor asyncConnectionThread;
|
||||||
|
|
||||||
// Connection state variables
|
// Connection state variables
|
||||||
|
|
Loading…
Reference in New Issue