[jboss-cvs] JBoss Messaging SVN: r5232 - branches/Branch_1_4/src/main/org/jboss/messaging/core/impl.

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

Author: timfox
Date: 2008-10-31 09:09:34 -0400 (Fri, 31 Oct 2008)
New Revision: 5232

Modified:
   branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/MessagingQueue.java
Log:
JBMESSAGING-1429


Modified: branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/MessagingQueue.java
===================================================================
--- branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/MessagingQueue.java	2008-10-31 12:00:37 UTC (rev 5231)
+++ branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/MessagingQueue.java	2008-10-31 13:09:34 UTC (rev 5232)
@@ -555,16 +555,19 @@
    
    // Private -------------------------------------------------------
    
-   private synchronized void informSuckers(boolean consume)
+   private void informSuckers(boolean consume)
    {
-   	Iterator iter = suckers.iterator();
-   	
-   	while (iter.hasNext())
-   	{
-   		MessageSucker sucker = (MessageSucker)iter.next();
-   		
-   		sucker.setConsuming(consume);
-   	}
+      synchronized (lock)
+      {
+      	Iterator iter = suckers.iterator();
+      	
+      	while (iter.hasNext())
+      	{
+      		MessageSucker sucker = (MessageSucker)iter.next();
+      		
+      		sucker.setConsuming(consume);
+      	}
+      }
    }
    
    // Inner classes -------------------------------------------------