[jboss-cvs] JBoss Messaging SVN: r2345 - trunk/src/main/org/jboss/jms/server/endpoint.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2007-02-19 06:59:00 -0500 (Mon, 19 Feb 2007)
New Revision: 2345

Modified:
   trunk/src/main/org/jboss/jms/server/endpoint/ServerConsumerEndpoint.java
Log:
Toggle on off to deal with one way invocations arriving out of order



Modified: trunk/src/main/org/jboss/jms/server/endpoint/ServerConsumerEndpoint.java
===================================================================
--- trunk/src/main/org/jboss/jms/server/endpoint/ServerConsumerEndpoint.java	2007-02-17 08:29:02 UTC (rev 2344)
+++ trunk/src/main/org/jboss/jms/server/endpoint/ServerConsumerEndpoint.java	2007-02-19 11:59:00 UTC (rev 2345)
@@ -376,13 +376,14 @@
          
          // No need to synchronize - clientAccepting is volatile
          
-         if (newRate == 0)
+         // We need to deal with the fact that one way invocations may arrive in a different order
+         // to that which they arrived in
+         // So we just toggle on / off
+         
+         clientAccepting = !clientAccepting;
+         
+         if (clientAccepting)
          {
-            clientAccepting = false;
-         }
-         else
-         {
-            clientAccepting = true;
             promptDelivery();
          }            
       }