diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2013-09-25 13:53:57 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2013-09-25 13:53:57 +0000 |
| commit | 309f2f88d0a10def70bff0b08e660a8dd57fe27f (patch) | |
| tree | 7dbc6b557f20751f41a069748ddd7f08fe5f958a /qpid/java | |
| parent | 92c158fc91f89205de3bc6d8a174f2f2303a3011 (diff) | |
| download | qpid-python-309f2f88d0a10def70bff0b08e660a8dd57fe27f.tar.gz | |
QPID-5166 : Lazily create dispatcher thread in JMS Session implementation (patch from dingham@microsoft.com)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1526177 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java index 2ae67913fe..02982a9cec 100644 --- a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java +++ b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java @@ -140,8 +140,6 @@ public class SessionImpl implements Session, QueueSession, TopicSession _messageFactory = new MessageFactory(this);
- _dispatcherThread = new Thread(_dispatcher);
- _dispatcherThread.start();
}
public BytesMessageImpl createBytesMessage() throws IllegalStateException
@@ -384,6 +382,12 @@ public class SessionImpl implements Session, QueueSession, TopicSession final MessageConsumerImpl messageConsumer;
synchronized(_session.getEndpoint().getLock())
{
+ if(_dispatcherThread == null)
+ {
+ _dispatcherThread = new Thread(_dispatcher);
+ _dispatcherThread.start();
+ }
+
messageConsumer = new MessageConsumerImpl(destination, this, selector, noLocal);
addConsumer(messageConsumer);
if(_connection.isStarted())
|