[jboss-cvs] JBoss Messaging SVN: r7145 - trunk/src/main/org/jboss/messaging/core/server/impl.

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

Author: jmesnil
Date: 2009-06-01 03:25:11 -0400 (Mon, 01 Jun 2009)
New Revision: 7145

Modified:
   trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java
Log:
Queue Message redistribution fix

* do not check the message references size when creating a queue's
  redistributor (check only if there are local consumers)

Modified: trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java	2009-06-01 02:36:10 UTC (rev 7144)
+++ trunk/src/main/org/jboss/messaging/core/server/impl/QueueImpl.java	2009-06-01 07:25:11 UTC (rev 7145)
@@ -455,7 +455,7 @@
 
       if (delay > 0)
       {
-         if (consumers.size() == 0 && messageReferences.size() > 0)
+         if (consumers.size() == 0)
          {
             DelayedAddRedistributor dar = new DelayedAddRedistributor(executor, replicatingChannel);
 
@@ -1050,7 +1050,7 @@
 
    private void internalAddRedistributor(final Executor executor, final Channel replicatingChannel)
    {
-      if (consumers.size() == 0 && messageReferences.size() > 0)
+      if (consumers.size() == 0)
       {
          redistributor = new Redistributor(this,
                                            storageManager,