[hornetq-commits] JBoss hornetq SVN: r8311 - trunk/src/main/org/hornetq/core/server/impl.
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;