[jboss-cvs] JBoss Messaging SVN: r5629 - branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/server/impl.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Tue Jan 13 20:12:44 EST 2009


Author: clebert.suconic at jboss.com
Date: 2009-01-13 20:12:44 -0500 (Tue, 13 Jan 2009)
New Revision: 5629

Modified:
   branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/server/impl/ServerConsumerImpl.java
Log:
tweak
(the lock being committed was just an accident)

Modified: branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/server/impl/ServerConsumerImpl.java
===================================================================
--- branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/server/impl/ServerConsumerImpl.java	2009-01-14 00:57:44 UTC (rev 5628)
+++ branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/server/impl/ServerConsumerImpl.java	2009-01-14 01:12:44 UTC (rev 5629)
@@ -483,25 +483,17 @@
 
    private void promptDelivery()
    {
-      lock.lock();
-      try
+      if (largeMessageSender != null)
       {
-         if (largeMessageSender != null)
+         if (largeMessageSender.sendLargeMessage())
          {
-            if (largeMessageSender.sendLargeMessage())
-            {
-               // prompt Delivery only if chunk was finished
-               session.promptDelivery(messageQueue);
-            }
-         }
-         else
-         {
+            // prompt Delivery only if chunk was finished
             session.promptDelivery(messageQueue);
          }
       }
-      finally
+      else
       {
-         lock.unlock();
+         session.promptDelivery(messageQueue);
       }
    }
 




More information about the jboss-cvs-commits mailing list