You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2013/09/25 15:53:58 UTC
svn commit: r1526177 -
/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java
Author: rgodfrey
Date: Wed Sep 25 13:53:57 2013
New Revision: 1526177
URL: http://svn.apache.org/r1526177
Log:
QPID-5166 : Lazily create dispatcher thread in JMS Session implementation (patch from dingham@microsoft.com)
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java
Modified: qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java?rev=1526177&r1=1526176&r2=1526177&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java (original)
+++ qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java Wed Sep 25 13:53:57 2013
@@ -140,8 +140,6 @@ public class SessionImpl implements Sess
_messageFactory = new MessageFactory(this);
- _dispatcherThread = new Thread(_dispatcher);
- _dispatcherThread.start();
}
public BytesMessageImpl createBytesMessage() throws IllegalStateException
@@ -384,6 +382,12 @@ public class SessionImpl implements Sess
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())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org