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:54:21 UTC
svn commit: r473657 -
/incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Author: jlim
Date: Fri Nov 10 22:54:20 2006
New Revision: 473657
URL: http://svn.apache.org/viewvc?view=rev&rev=473657
Log:
fix for http://issues.apache.org/activemq/browse/AMQ-1042
Modified:
incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Modified: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java?view=diff&rev=473657&r1=473656&r2=473657
==============================================================================
--- incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java (original)
+++ incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java Fri Nov 10 22:54:20 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);
}