[Jboss-cvs] JBoss Messaging SVN: r1223 - trunk/src/main/org/jboss/messaging/core/local

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

Author: ovidiu.feodorov at jboss.com
Date: 2006-08-10 15:04:47 -0400 (Thu, 10 Aug 2006)
New Revision: 1223

Modified:
   trunk/src/main/org/jboss/messaging/core/local/RoundRobinPointToPointRouter.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-505

Modified: trunk/src/main/org/jboss/messaging/core/local/RoundRobinPointToPointRouter.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/local/RoundRobinPointToPointRouter.java	2006-08-10 18:51:44 UTC (rev 1222)
+++ trunk/src/main/org/jboss/messaging/core/local/RoundRobinPointToPointRouter.java	2006-08-10 19:04:47 UTC (rev 1223)
@@ -215,6 +215,11 @@
       synchronized(receivers)
       {
          int size = receivers.size();
+         if (size == 0)
+         {
+            // target has already been reset by remove()
+            return;
+         }
          target = Math.max((target + 1) % size, (currentTarget + 1) % size);
       }
    }