[hornetq-commits] JBoss hornetq SVN: r8311 - trunk/src/main/org/hornetq/core/server/impl.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-11-18 11:47:53 -0500 (Wed, 18 Nov 2009)
New Revision: 8311

Modified:
   trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java
Log:
HORNETQ-220: Swallowed IIOBE on the Queue's Handler

* reset the handlers' pos when a handler is removed

Modified: trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java	2009-11-18 15:11:45 UTC (rev 8310)
+++ trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java	2009-11-18 16:47:53 UTC (rev 8311)
@@ -895,6 +895,10 @@
          {
             iter.remove();
 
+            if (pos >= handlers.size())
+            {
+               pos = 0;
+            }
             removed = true;
 
             break;