diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-02-02 13:56:14 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-02-02 13:56:14 +0000 |
| commit | 8ceca1598f2ef8dafd45704828a75206796f429a (patch) | |
| tree | 3d288b41ff823702042bf44b44122d1ba9c898c9 /qpid/java/client/src/main | |
| parent | 81072fc8cd9ae820d211684943063d9b38037ee4 (diff) | |
| download | qpid-python-8ceca1598f2ef8dafd45704828a75206796f429a.tar.gz | |
QPID-3784: introduce system property to run a dispatcher thread as damon/non-daemon thread. Changes dispatcher thread to be non daemon thread by default.
Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com>.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1239620 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src/main')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 82ba04ddd3..f56f0c2747 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -387,6 +387,16 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic /** Immediate message prefetch default. */ public static final String IMMEDIATE_PREFETCH_DEFAULT = "false"; + /** + * System property to enable allow dispatcher thread to be run as a daemon thread + */ + public static final String DAEMON_DISPATCHER = "qpid.jms.daemon.dispatcher"; + + /** + * Flag indicating to start dispatcher as a daemon thread + */ + protected final boolean DEAMON_DISPATCHER_THREAD = Boolean.getBoolean(DAEMON_DISPATCHER); + /** The connection to which this session belongs. */ private AMQConnection _connection; @@ -2463,7 +2473,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic throw new Error("Error creating Dispatcher thread",e); } _dispatcherThread.setName("Dispatcher-Channel-" + _channelId); - _dispatcherThread.setDaemon(true); + _dispatcherThread.setDaemon(DEAMON_DISPATCHER_THREAD); _dispatcher.setConnectionStopped(initiallyStopped); _dispatcherThread.start(); if (_dispatcherLogger.isInfoEnabled()) |