[jboss-cvs] JBoss Messaging SVN: r2949 - in trunk: tests/src/org/jboss/test/messaging/jms/clustering and 1 other directory.

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

Author: timfox
Date: 2007-08-03 07:41:33 -0400 (Fri, 03 Aug 2007)
New Revision: 2949

Modified:
   trunk/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
   trunk/tests/src/org/jboss/test/messaging/jms/clustering/ChangeFailoverNodeTest.java
Log:
temp logging


Modified: trunk/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2007-08-03 09:54:07 UTC (rev 2948)
+++ trunk/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2007-08-03 11:41:33 UTC (rev 2949)
@@ -460,9 +460,11 @@
    					ClusterRequest request = new GetReplicatedDeliveriesRequest(binding.queue.getName(), replyAddress);
    					
    				   info = (PostOfficeAddressInfo)nodeIDAddressMap.get(masterNodeID);
+   				   			   
+   				   Address address = info.getControlChannelAddress();
    				   
-   				   Address address = info.getControlChannelAddress();
-   				   	
+   				   log.info("Sending the message to node " + masterNodeID + " with address " + address);
+   			   	   				   	
    				   if (address != null)
    				   {	   
    				   	groupMember.unicastControl(request, address, false);

Modified: trunk/tests/src/org/jboss/test/messaging/jms/clustering/ChangeFailoverNodeTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/clustering/ChangeFailoverNodeTest.java	2007-08-03 09:54:07 UTC (rev 2948)
+++ trunk/tests/src/org/jboss/test/messaging/jms/clustering/ChangeFailoverNodeTest.java	2007-08-03 11:41:33 UTC (rev 2949)
@@ -722,7 +722,7 @@
       	//Don't ack
       	
       	//We stop the failover node for node 1
-      	int failoverNodeId = this.getFailoverNodeForNode(factory, 1);
+      	int failoverNodeId = this.getFailoverNodeForNode(factory, 1);      	      	
       	
       	int recoveryMapSize = ServerManagement.getServer(failoverNodeId).getRecoveryMapSize(queueName);
       	assertEquals(0, recoveryMapSize);