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

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

Author: ataylor
Date: 2008-09-30 10:44:41 -0400 (Tue, 30 Sep 2008)
New Revision: 5048

Modified:
   trunk/src/main/org/jboss/messaging/core/server/impl/RoundRobinDistributionPolicy.java
Log:
off by one error fixed

Modified: trunk/src/main/org/jboss/messaging/core/server/impl/RoundRobinDistributionPolicy.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/server/impl/RoundRobinDistributionPolicy.java	2008-09-30 14:23:16 UTC (rev 5047)
+++ trunk/src/main/org/jboss/messaging/core/server/impl/RoundRobinDistributionPolicy.java	2008-09-30 14:44:41 UTC (rev 5048)
@@ -46,12 +46,13 @@
       {
          //First time
          pos = 0;
+         return consumers.get(pos);   
       }
       else
       {
          pos++;
          
-         if (pos == consumers.size() - 1)
+         if (pos == consumers.size())
          {
             pos = 0;
          }
@@ -59,4 +60,17 @@
 
       return consumers.get(pos);
    }
+
+   public synchronized void addConsumer(Consumer consumer)
+   {
+      pos = -1;
+      super.addConsumer(consumer);
+   }
+
+   public synchronized boolean removeConsumer(Consumer consumer)
+   {
+
+      pos = -1;
+      return super.removeConsumer(consumer);
+   }
 }