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

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

Author: timfox
Date: 2007-08-23 15:06:42 -0400 (Thu, 23 Aug 2007)
New Revision: 3048

Modified:
   trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java
Log:
Fixed minor bug in cluster connection manager


Modified: trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java	2007-08-23 19:02:05 UTC (rev 3047)
+++ trunk/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java	2007-08-23 19:06:42 UTC (rev 3048)
@@ -441,7 +441,7 @@
 		
 		ConnectionInfo localInfo = (ConnectionInfo)connections.get(new Integer(this.nodeID));
 		
-		if (info == null)
+		if (localInfo == null)
 		{
 			if (trace) { log.trace("Cluster pull connection factory has not yet been deployed on local node"); }
 			
@@ -460,12 +460,10 @@
 			
 			Queue localQueue = binding.queue;
 			
-			log.info("local queue is: " + localQueue);
-			
 			if (localQueue.isClustered())
-			{							
+			{				
 				MessageSucker sucker = new MessageSucker(localQueue, info.connection, localInfo.connection, xa, preserveOrdering);
-				
+	
 				info.addSucker(sucker);
 				
 				sucker.start();