You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jl...@apache.org on 2006/11/11 07:09:59 UTC
svn commit: r473647 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Author: jlim
Date: Fri Nov 10 22:09:59 2006
New Revision: 473647
URL: http://svn.apache.org/viewvc?view=rev&rev=473647
Log:
fixed for http://issues.apache.org/activemq/browse/AMQ-1042
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java?view=diff&rev=473647&r1=473646&r2=473647
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java Fri Nov 10 22:09:59 2006
@@ -856,6 +856,9 @@
}
}
}
+ // yeild here so that a thread trying to stop unconsumedMessages has
+ // a chance of getting prioritized head of this thread that is in a dispatch loop.
+ Thread.yield();
} catch (Exception e) {
session.connection.onAsyncException(e);
}