[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