[jboss-cvs] JBoss Messaging SVN: r2069 - trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster.

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

Author: timfox
Date: 2007-01-26 13:34:22 -0500 (Fri, 26 Jan 2007)
New Revision: 2069

Modified:
   trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOfficeTest.java
   trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/JGroupsUtil.java
Log:
Tweak


Modified: trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOfficeTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOfficeTest.java	2007-01-26 17:51:28 UTC (rev 2068)
+++ trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOfficeTest.java	2007-01-26 18:34:22 UTC (rev 2069)
@@ -156,20 +156,28 @@
          
          office1 = createClusteredPostOffice(1, "testgroup");
          
+         log.info("Created office1");
+         
          //Add a couple of bindings
          
          LocalClusteredQueue queue1 = new LocalClusteredQueue(office1, 1, "sub1", channelIDManager.getID(), ms, pm, true, false, (QueuedExecutor)pool.get(), -1, null, tr);
          Binding binding1 =
             office1.bindClusteredQueue(new SimpleCondition("topic1"), queue1);
          
+         log.info("Added binding1");
+         
          LocalClusteredQueue queue2 = new LocalClusteredQueue(office1, 1, "sub2", channelIDManager.getID(), ms, pm, true, false, (QueuedExecutor)pool.get(), -1, null, tr);
          Binding binding2 =
             office1.bindClusteredQueue(new SimpleCondition("topic1"), queue2);
          
+         log.info("Added binding2");
+         
          //Start another office - make sure it picks up the bindings from the first node
          
          office2 = createClusteredPostOffice(2, "testgroup");
          
+         log.info("Created office 2");
+         
          Collection bindings = office2.listAllBindingsForCondition(new SimpleCondition("topic1"));
          assertNotNull(bindings);
          assertEquals(2, bindings.size());

Modified: trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/JGroupsUtil.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/JGroupsUtil.java	2007-01-26 17:51:28 UTC (rev 2068)
+++ trunk/tests/src/org/jboss/test/messaging/core/plugin/postoffice/cluster/JGroupsUtil.java	2007-01-26 18:34:22 UTC (rev 2069)
@@ -102,7 +102,7 @@
 //      }
      
       return "UDP(mcast_recv_buf_size=500000;down_thread=false;ip_mcast=true;mcast_send_buf_size=32000;"+
-      "mcast_port=45567;ucast_recv_buf_size=500000;use_incoming_packet_handler=false;"+
+      "mcast_port=45568;ucast_recv_buf_size=500000;use_incoming_packet_handler=false;"+
       "mcast_addr=228.8.8.8;use_outgoing_packet_handler=true;loopback=true;ucast_send_buf_size=32000;ip_ttl=32;"+
       "bind_addr=127.0.0.1):"+
       "AUTOCONF(down_thread=false;up_thread=false):"+