activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject svn commit: r473657 - /incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Date Sat, 11 Nov 2006 06:54:21 GMT
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);
         }



Mime
View raw message