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

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

Author: timfox
Date: 2007-10-19 19:27:49 -0400 (Fri, 19 Oct 2007)
New Revision: 3215

Modified:
   trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
Log:
tweak


Modified: trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2007-10-19 22:59:29 UTC (rev 3214)
+++ trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2007-10-19 23:27:49 UTC (rev 3215)
@@ -203,7 +203,7 @@
 		return this.localQueue.getName();
 	}
 	
-	public void setConsuming(boolean consume)
+	public synchronized void setConsuming(boolean consume)
 	{
 		if (trace) { log.trace(this + " setConsuming " + consume); }