[jboss-cvs] JBoss Messaging SVN: r5376 - in branches/Branch_1_4/tests: etc/server/default/deploy and 2 other directories.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Mon Nov 17 18:02:35 EST 2008


Author: clebert.suconic at jboss.com
Date: 2008-11-17 18:02:35 -0500 (Mon, 17 Nov 2008)
New Revision: 5376

Modified:
   branches/Branch_1_4/tests/build.xml
   branches/Branch_1_4/tests/etc/server/default/deploy/mock-channelfactory-stacks.xml
   branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/PostOfficeTestBase.java
   branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPersistenceServiceConfigFileJChannelFactory.java
Log:
Fixing test after latest JGroups update for Jboss5

Modified: branches/Branch_1_4/tests/build.xml
===================================================================
--- branches/Branch_1_4/tests/build.xml	2008-11-17 21:28:16 UTC (rev 5375)
+++ branches/Branch_1_4/tests/build.xml	2008-11-17 23:02:35 UTC (rev 5376)
@@ -333,6 +333,7 @@
 			<sysproperty key="jboss.messaging.datachanneludpaddress" value="${jboss.messaging.datachanneludpaddress}" />
 			<sysproperty key="jboss.messaging.controlchanneludpaddress" value="${jboss.messaging.controlchanneludpaddress}" />
 			<sysproperty key="jboss.messaging.ipttl" value="${jboss.messaging.ipttl}" />
+			<sysproperty key="java.net.preferIPv4Stack" value="true" />
 			<sysproperty key="test.database" value="${functional.tests.database}" />
 			<sysproperty key="test.logfile.suffix" value="invm" />
 			<sysproperty key="build.lib" value="${build.lib}" />
@@ -409,7 +410,7 @@
 		<echo message="" />
 		<echo message="Running remote tests, junit.batchtest.fork=${junit.batchtest.fork}, remoting=${test.remoting}" />
 		<echo message="" />
-
+		
 		<junit printsummary="${junit.printsummary}" fork="on" forkMode="once" includeantruntime="yes" haltonerror="${junit.haltonerror}" haltonfailure="${junit.haltonfailure}" showoutput="${junit.showoutput}" timeout="${junit.timeout}">
 
 			<sysproperty key="remote" value="true" />
@@ -420,6 +421,15 @@
 			<sysproperty key="test.remoting" value="${test.remoting}" />
 			<sysproperty key="test.logfile.suffix" value="remote-client" />
 			<sysproperty key="objectstore.dir" value="${objectstore.dir}" />
+
+			<sysproperty key="jboss.messaging.groupname" value="${jboss.messaging.groupname}" />
+			<sysproperty key="jboss.messaging.datachanneludpport" value="${jboss.messaging.datachanneludpport}" />
+			<sysproperty key="jboss.messaging.controlchanneludpport" value="${jboss.messaging.controlchanneludpport}" />
+			<sysproperty key="jboss.messaging.datachanneludpaddress" value="${jboss.messaging.datachanneludpaddress}" />
+			<sysproperty key="jboss.messaging.controlchanneludpaddress" value="${jboss.messaging.controlchanneludpaddress}" />
+			<sysproperty key="jboss.messaging.ipttl" value="${jboss.messaging.ipttl}" />
+			<sysproperty key="java.net.preferIPv4Stack" value="true" />
+			
 			<jvmarg value="-Xmx512M" />
 			<!--
          <jvmarg line="-Xdebug -Xnoagent -Djava.compiler=NONE -Xrunjdwp:transport=dt_shmem,server=n,suspend=n,address=antjunit"/>

Modified: branches/Branch_1_4/tests/etc/server/default/deploy/mock-channelfactory-stacks.xml
===================================================================
--- branches/Branch_1_4/tests/etc/server/default/deploy/mock-channelfactory-stacks.xml	2008-11-17 21:28:16 UTC (rev 5375)
+++ branches/Branch_1_4/tests/etc/server/default/deploy/mock-channelfactory-stacks.xml	2008-11-17 23:02:35 UTC (rev 5376)
@@ -129,6 +129,511 @@
         </config>
     </stack>
            
+    <!-- ClusteredPostOfficeTest needs to run multiple JGroups instances inside the same VM, and we need multiple stacks for that --> 
+    
+    
+    <stack name="jbm-control_1"
+           description="Stack optimized for the JBoss Messaging Control Channel">
+       <config>
+	        <UDP
+	             singleton_name="shared-udp_1"
+	             mcast_port="${jboss.jgroups.udp.mcast_port:45688}"
+	             mcast_addr="${jgroups.udp.mcast_addr:228.11.11.11}"
+	             tos="8"
+	             ucast_recv_buf_size="20000000"
+	             ucast_send_buf_size="640000"
+	             mcast_recv_buf_size="25000000"
+	             mcast_send_buf_size="640000"
+	             loopback="true"
+	             discard_incompatible_packets="true"
+	             enable_bundling="false"
+	             max_bundle_size="64000"
+	             max_bundle_timeout="30"
+	             use_incoming_packet_handler="true"
+	             ip_ttl="${jgroups.udp.ip_ttl:2}"
+	             thread_naming_pattern="cl"
+	             timer.num_threads="12"
+	                         
+	             use_concurrent_stack="true"
+	        
+	             thread_pool.enabled="true"
+	             thread_pool.min_threads="20"
+	             thread_pool.max_threads="200"
+	             thread_pool.keep_alive_time="5000"
+	             thread_pool.queue_enabled="true"
+	             thread_pool.queue_max_size="1000"
+	             thread_pool.rejection_policy="discard"
+	              
+	             oob_thread_pool.enabled="true"
+	             oob_thread_pool.min_threads="1"
+	             oob_thread_pool.max_threads="20"
+	             oob_thread_pool.keep_alive_time="5000"
+	             oob_thread_pool.queue_enabled="false"
+	             oob_thread_pool.queue_max_size="100"
+	             oob_thread_pool.rejection_policy="run"/>
+            <PING timeout="2000"
+                  num_initial_members="3"/>
+            <MERGE2 max_interval="100000"
+                    min_interval="20000"/>
+            <FD_SOCK />
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500" />
+            <BARRIER />
+            <pbcast.NAKACK use_stats_for_retransmission="false"
+                   exponential_backoff="150"
+                   use_mcast_xmit="true" gc_lag="0"
+                   retransmit_timeout="50,300,600,1200"
+                   discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true"
+                view_bundling="true"/>
+            <FC max_credits="500000"
+                    min_threshold="0.20"/>
+            <FRAG2 frag_size="60000"  />
+            <pbcast.STATE_TRANSFER/>
+            <pbcast.FLUSH timeout="20000"/>
+        </config>
+    </stack>
+    
+    <stack name="jbm-data_1"
+           description="Stack optimized for the JBoss Messaging Data Channel">
+        <config>
+            <TCP singleton_name="jbm-data_1"
+                 start_port="7900"
+                 loopback="true"
+                 recv_buf_size="20000000"
+                 send_buf_size="640000"
+                 discard_incompatible_packets="true"
+                 max_bundle_size="64000"
+                 max_bundle_timeout="30"
+                 use_incoming_packet_handler="true"
+                 enable_bundling="false"
+                 use_send_queues="false"
+                 sock_conn_timeout="300"
+                 skip_suspected_members="true"
+                 
+                 use_concurrent_stack="true" 
+                 
+                 thread_pool.enabled="true"
+                 thread_pool.min_threads="8"
+                 thread_pool.max_threads="200"
+                 thread_pool.keep_alive_time="5000"
+                 thread_pool.queue_enabled="true" 
+                 thread_pool.queue_max_size="500"
+                 thread_pool.rejection_policy="discard"
+                 
+                 oob_thread_pool.enabled="true"
+                 oob_thread_pool.min_threads="1"
+                 oob_thread_pool.max_threads="100" 
+                 oob_thread_pool.keep_alive_time="5000"
+                 oob_thread_pool.queue_enabled="false"
+                 oob_thread_pool.queue_max_size="100"
+                 oob_thread_pool.rejection_policy="run"/>
+            <MPING timeout="5000"
+               mcast_addr="${jboss.messaging.datachanneludpaddress,jboss.partition.udpGroup:228.6.6.6}"
+               mcast_port="${jboss.messaging.datachanneludpport:45567}"
+               ip_ttl="${jboss.messaging.ipttl:8}"
+               num_initial_members="5"
+               num_ping_requests="3"/>
+            <MERGE2 max_interval="100000" min_interval="20000"/>
+            <FD_SOCK/>
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500"/>
+            <BARRIER/>
+            <pbcast.NAKACK use_mcast_xmit="false" gc_lag="0"
+                           retransmit_timeout="300,600,1200,2400,4800"
+                           discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true" view_bundling="true"/>
+        </config>
+    </stack>
+
+    <stack name="jbm-control_2"
+           description="Stack optimized for the JBoss Messaging Control Channel">
+       <config>
+	        <UDP
+	             singleton_name="shared-udp_2"
+	             mcast_port="${jboss.jgroups.udp.mcast_port:45688}"
+	             mcast_addr="${jgroups.udp.mcast_addr:228.11.11.11}"
+	             tos="8"
+	             ucast_recv_buf_size="20000000"
+	             ucast_send_buf_size="640000"
+	             mcast_recv_buf_size="25000000"
+	             mcast_send_buf_size="640000"
+	             loopback="true"
+	             discard_incompatible_packets="true"
+	             enable_bundling="false"
+	             max_bundle_size="64000"
+	             max_bundle_timeout="30"
+	             use_incoming_packet_handler="true"
+	             ip_ttl="${jgroups.udp.ip_ttl:2}"
+	             thread_naming_pattern="cl"
+	             timer.num_threads="12"
+	                         
+	             use_concurrent_stack="true"
+	        
+	             thread_pool.enabled="true"
+	             thread_pool.min_threads="20"
+	             thread_pool.max_threads="200"
+	             thread_pool.keep_alive_time="5000"
+	             thread_pool.queue_enabled="true"
+	             thread_pool.queue_max_size="1000"
+	             thread_pool.rejection_policy="discard"
+	              
+	             oob_thread_pool.enabled="true"
+	             oob_thread_pool.min_threads="1"
+	             oob_thread_pool.max_threads="20"
+	             oob_thread_pool.keep_alive_time="5000"
+	             oob_thread_pool.queue_enabled="false"
+	             oob_thread_pool.queue_max_size="100"
+	             oob_thread_pool.rejection_policy="run"/>
+            <PING timeout="2000"
+                  num_initial_members="3"/>
+            <MERGE2 max_interval="100000"
+                    min_interval="20000"/>
+            <FD_SOCK />
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500" />
+            <BARRIER />
+            <pbcast.NAKACK use_stats_for_retransmission="false"
+                   exponential_backoff="150"
+                   use_mcast_xmit="true" gc_lag="0"
+                   retransmit_timeout="50,300,600,1200"
+                   discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true"
+                view_bundling="true"/>
+            <FC max_credits="500000"
+                    min_threshold="0.20"/>
+            <FRAG2 frag_size="60000"  />
+            <pbcast.STATE_TRANSFER/>
+            <pbcast.FLUSH timeout="20000"/>
+        </config>
+    </stack>
+    
+    <stack name="jbm-data_2"
+           description="Stack optimized for the JBoss Messaging Data Channel">
+        <config>
+            <TCP singleton_name="jbm-data_2"
+                 start_port="7900"
+                 loopback="true"
+                 recv_buf_size="20000000"
+                 send_buf_size="640000"
+                 discard_incompatible_packets="true"
+                 max_bundle_size="64000"
+                 max_bundle_timeout="30"
+                 use_incoming_packet_handler="true"
+                 enable_bundling="false"
+                 use_send_queues="false"
+                 sock_conn_timeout="300"
+                 skip_suspected_members="true"
+                 
+                 use_concurrent_stack="true" 
+                 
+                 thread_pool.enabled="true"
+                 thread_pool.min_threads="8"
+                 thread_pool.max_threads="200"
+                 thread_pool.keep_alive_time="5000"
+                 thread_pool.queue_enabled="true" 
+                 thread_pool.queue_max_size="500"
+                 thread_pool.rejection_policy="discard"
+                 
+                 oob_thread_pool.enabled="true"
+                 oob_thread_pool.min_threads="1"
+                 oob_thread_pool.max_threads="100" 
+                 oob_thread_pool.keep_alive_time="5000"
+                 oob_thread_pool.queue_enabled="false"
+                 oob_thread_pool.queue_max_size="100"
+                 oob_thread_pool.rejection_policy="run"/>
+            <MPING timeout="5000"
+               mcast_addr="${jboss.messaging.datachanneludpaddress,jboss.partition.udpGroup:228.6.6.6}"
+               mcast_port="${jboss.messaging.datachanneludpport:45567}"
+               ip_ttl="${jboss.messaging.ipttl:8}"
+               num_initial_members="5"
+               num_ping_requests="3"/>
+            <MERGE2 max_interval="100000" min_interval="20000"/>
+            <FD_SOCK/>
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500"/>
+            <BARRIER/>
+            <pbcast.NAKACK use_mcast_xmit="false" gc_lag="0"
+                           retransmit_timeout="300,600,1200,2400,4800"
+                           discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true" view_bundling="true"/>
+        </config>
+    </stack>
+           
+    <stack name="jbm-control_3"
+           description="Stack optimized for the JBoss Messaging Control Channel">
+       <config>
+	        <UDP
+	             singleton_name="shared-udp_3"
+	             mcast_port="${jboss.jgroups.udp.mcast_port:45688}"
+	             mcast_addr="${jgroups.udp.mcast_addr:228.11.11.11}"
+	             tos="8"
+	             ucast_recv_buf_size="20000000"
+	             ucast_send_buf_size="640000"
+	             mcast_recv_buf_size="25000000"
+	             mcast_send_buf_size="640000"
+	             loopback="true"
+	             discard_incompatible_packets="true"
+	             enable_bundling="false"
+	             max_bundle_size="64000"
+	             max_bundle_timeout="30"
+	             use_incoming_packet_handler="true"
+	             ip_ttl="${jgroups.udp.ip_ttl:2}"
+	             thread_naming_pattern="cl"
+	             timer.num_threads="12"
+	                         
+	             use_concurrent_stack="true"
+	        
+	             thread_pool.enabled="true"
+	             thread_pool.min_threads="20"
+	             thread_pool.max_threads="200"
+	             thread_pool.keep_alive_time="5000"
+	             thread_pool.queue_enabled="true"
+	             thread_pool.queue_max_size="1000"
+	             thread_pool.rejection_policy="discard"
+	              
+	             oob_thread_pool.enabled="true"
+	             oob_thread_pool.min_threads="1"
+	             oob_thread_pool.max_threads="20"
+	             oob_thread_pool.keep_alive_time="5000"
+	             oob_thread_pool.queue_enabled="false"
+	             oob_thread_pool.queue_max_size="100"
+	             oob_thread_pool.rejection_policy="run"/>
+            <PING timeout="2000"
+                  num_initial_members="3"/>
+            <MERGE2 max_interval="100000"
+                    min_interval="20000"/>
+            <FD_SOCK />
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500" />
+            <BARRIER />
+            <pbcast.NAKACK use_stats_for_retransmission="false"
+                   exponential_backoff="150"
+                   use_mcast_xmit="true" gc_lag="0"
+                   retransmit_timeout="50,300,600,1200"
+                   discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true"
+                view_bundling="true"/>
+            <FC max_credits="500000"
+                    min_threshold="0.20"/>
+            <FRAG2 frag_size="60000"  />
+            <pbcast.STATE_TRANSFER/>
+            <pbcast.FLUSH timeout="20000"/>
+        </config>
+    </stack>
+    
+    <stack name="jbm-data_3"
+           description="Stack optimized for the JBoss Messaging Data Channel">
+        <config>
+            <TCP singleton_name="jbm-data_3"
+                 start_port="7900"
+                 loopback="true"
+                 recv_buf_size="20000000"
+                 send_buf_size="640000"
+                 discard_incompatible_packets="true"
+                 max_bundle_size="64000"
+                 max_bundle_timeout="30"
+                 use_incoming_packet_handler="true"
+                 enable_bundling="false"
+                 use_send_queues="false"
+                 sock_conn_timeout="300"
+                 skip_suspected_members="true"
+                 
+                 use_concurrent_stack="true" 
+                 
+                 thread_pool.enabled="true"
+                 thread_pool.min_threads="8"
+                 thread_pool.max_threads="200"
+                 thread_pool.keep_alive_time="5000"
+                 thread_pool.queue_enabled="true" 
+                 thread_pool.queue_max_size="500"
+                 thread_pool.rejection_policy="discard"
+                 
+                 oob_thread_pool.enabled="true"
+                 oob_thread_pool.min_threads="1"
+                 oob_thread_pool.max_threads="100" 
+                 oob_thread_pool.keep_alive_time="5000"
+                 oob_thread_pool.queue_enabled="false"
+                 oob_thread_pool.queue_max_size="100"
+                 oob_thread_pool.rejection_policy="run"/>
+            <MPING timeout="5000"
+               mcast_addr="${jboss.messaging.datachanneludpaddress,jboss.partition.udpGroup:228.6.6.6}"
+               mcast_port="${jboss.messaging.datachanneludpport:45567}"
+               ip_ttl="${jboss.messaging.ipttl:8}"
+               num_initial_members="5"
+               num_ping_requests="3"/>
+            <MERGE2 max_interval="100000" min_interval="20000"/>
+            <FD_SOCK/>
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500"/>
+            <BARRIER/>
+            <pbcast.NAKACK use_mcast_xmit="false" gc_lag="0"
+                           retransmit_timeout="300,600,1200,2400,4800"
+                           discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true" view_bundling="true"/>
+        </config>
+    </stack>
+           
+           
+    <stack name="jbm-control_4"
+           description="Stack optimized for the JBoss Messaging Control Channel">
+       <config>
+	        <UDP
+	             singleton_name="shared-udp_4"
+	             mcast_port="${jboss.jgroups.udp.mcast_port:45688}"
+	             mcast_addr="${jgroups.udp.mcast_addr:228.11.11.11}"
+	             tos="8"
+	             ucast_recv_buf_size="20000000"
+	             ucast_send_buf_size="640000"
+	             mcast_recv_buf_size="25000000"
+	             mcast_send_buf_size="640000"
+	             loopback="true"
+	             discard_incompatible_packets="true"
+	             enable_bundling="false"
+	             max_bundle_size="64000"
+	             max_bundle_timeout="30"
+	             use_incoming_packet_handler="true"
+	             ip_ttl="${jgroups.udp.ip_ttl:2}"
+	             thread_naming_pattern="cl"
+	             timer.num_threads="12"
+	                         
+	             use_concurrent_stack="true"
+	        
+	             thread_pool.enabled="true"
+	             thread_pool.min_threads="20"
+	             thread_pool.max_threads="200"
+	             thread_pool.keep_alive_time="5000"
+	             thread_pool.queue_enabled="true"
+	             thread_pool.queue_max_size="1000"
+	             thread_pool.rejection_policy="discard"
+	              
+	             oob_thread_pool.enabled="true"
+	             oob_thread_pool.min_threads="1"
+	             oob_thread_pool.max_threads="20"
+	             oob_thread_pool.keep_alive_time="5000"
+	             oob_thread_pool.queue_enabled="false"
+	             oob_thread_pool.queue_max_size="100"
+	             oob_thread_pool.rejection_policy="run"/>
+            <PING timeout="2000"
+                  num_initial_members="3"/>
+            <MERGE2 max_interval="100000"
+                    min_interval="20000"/>
+            <FD_SOCK />
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500" />
+            <BARRIER />
+            <pbcast.NAKACK use_stats_for_retransmission="false"
+                   exponential_backoff="150"
+                   use_mcast_xmit="true" gc_lag="0"
+                   retransmit_timeout="50,300,600,1200"
+                   discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true"
+                view_bundling="true"/>
+            <FC max_credits="500000"
+                    min_threshold="0.20"/>
+            <FRAG2 frag_size="60000"  />
+            <pbcast.STATE_TRANSFER/>
+            <pbcast.FLUSH timeout="20000"/>
+        </config>
+    </stack>
+    
+    <stack name="jbm-data_4"
+           description="Stack optimized for the JBoss Messaging Data Channel">
+        <config>
+            <TCP singleton_name="jbm-data_4"
+                 start_port="7900"
+                 loopback="true"
+                 recv_buf_size="20000000"
+                 send_buf_size="640000"
+                 discard_incompatible_packets="true"
+                 max_bundle_size="64000"
+                 max_bundle_timeout="30"
+                 use_incoming_packet_handler="true"
+                 enable_bundling="false"
+                 use_send_queues="false"
+                 sock_conn_timeout="300"
+                 skip_suspected_members="true"
+                 
+                 use_concurrent_stack="true" 
+                 
+                 thread_pool.enabled="true"
+                 thread_pool.min_threads="8"
+                 thread_pool.max_threads="200"
+                 thread_pool.keep_alive_time="5000"
+                 thread_pool.queue_enabled="true" 
+                 thread_pool.queue_max_size="500"
+                 thread_pool.rejection_policy="discard"
+                 
+                 oob_thread_pool.enabled="true"
+                 oob_thread_pool.min_threads="1"
+                 oob_thread_pool.max_threads="100" 
+                 oob_thread_pool.keep_alive_time="5000"
+                 oob_thread_pool.queue_enabled="false"
+                 oob_thread_pool.queue_max_size="100"
+                 oob_thread_pool.rejection_policy="run"/>
+            <MPING timeout="5000"
+               mcast_addr="${jboss.messaging.datachanneludpaddress,jboss.partition.udpGroup:228.6.6.6}"
+               mcast_port="${jboss.messaging.datachanneludpport:45567}"
+               ip_ttl="${jboss.messaging.ipttl:8}"
+               num_initial_members="5"
+               num_ping_requests="3"/>
+            <MERGE2 max_interval="100000" min_interval="20000"/>
+            <FD_SOCK/>
+            <FD timeout="6000" max_tries="5" shun="true"/>
+            <VERIFY_SUSPECT timeout="1500"/>
+            <BARRIER/>
+            <pbcast.NAKACK use_mcast_xmit="false" gc_lag="0"
+                           retransmit_timeout="300,600,1200,2400,4800"
+                           discard_delivered_msgs="true"/>
+            <UNICAST timeout="300,600,1200,2400,3600"/>
+            <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+                           max_bytes="400000"/>
+            <VIEW_SYNC avg_send_interval="10000"/>
+
+            <pbcast.GMS print_local_addr="true" join_timeout="3000"
+                shun="true" view_bundling="true"/>
+        </config>
+    </stack>
+           
+           
 </protocol_stacks>
 
 

Modified: branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/PostOfficeTestBase.java
===================================================================
--- branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/PostOfficeTestBase.java	2008-11-17 21:28:16 UTC (rev 5375)
+++ branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/PostOfficeTestBase.java	2008-11-17 23:02:35 UTC (rev 5376)
@@ -44,7 +44,9 @@
 import org.jboss.messaging.core.impl.tx.TransactionRepository;
 import org.jboss.test.messaging.MessagingTestCase;
 import org.jboss.test.messaging.core.postoffice.ClusteredPersistenceServiceConfigFileJChannelFactory;
+import org.jboss.test.messaging.tools.container.ServiceConfigHelper;
 import org.jboss.test.messaging.tools.container.ServiceContainer;
+import org.jboss.test.messaging.tools.jboss.MBeanConfigurationElement;
 import org.jboss.test.messaging.util.CoreMessageFactory;
 
 /**
@@ -84,9 +86,9 @@
 
       String configFilePath = sc.getPersistenceConfigFile(true);
 
+
       ChannelFactory jChannelFactory =
-         new ClusteredPersistenceServiceConfigFileJChannelFactory(configFilePath,
-                                                                  sc.getMBeanServer());
+         new ClusteredPersistenceServiceConfigFileJChannelFactory(configFilePath, sc.getMBeanServer(), nodeID);
 
       MessagingPostOffice postOffice =
          new MessagingPostOffice(sc.getDataSource(), sc.getTransactionManager(),

Modified: branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPersistenceServiceConfigFileJChannelFactory.java
===================================================================
--- branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPersistenceServiceConfigFileJChannelFactory.java	2008-11-17 21:28:16 UTC (rev 5375)
+++ branches/Branch_1_4/tests/src/org/jboss/test/messaging/core/postoffice/ClusteredPersistenceServiceConfigFileJChannelFactory.java	2008-11-17 23:02:35 UTC (rev 5376)
@@ -49,6 +49,8 @@
    // ... or just plain XML configuration.
    private Element controlConfig;
    private Element dataConfig;
+   
+   private final int node;
 
    // Constructors ---------------------------------------------------------------------------------
 
@@ -67,9 +69,20 @@
       throws Exception
    {
       this.configFilePath = configFilePath;
+      this.node=-1;
       init(configFilePath, mbeanServer);
    }
 
+   public ClusteredPersistenceServiceConfigFileJChannelFactory(String configFilePath,
+                                                               MBeanServer mbeanServer,
+                                                               int node)
+      throws Exception
+   {
+      this.configFilePath = configFilePath;
+      this.node=node;
+      init(configFilePath, mbeanServer);
+   }
+
    // ChannelFactory ------------------------------------------------------------------------------
 
    public Channel createControlChannel() throws Exception
@@ -140,13 +153,23 @@
             throw new IllegalStateException("Cannot find ControlChannelName");
          }
 
+         if (node > 0)
+         {
+            controlChannelName += "_" + node;
+         }
+
          String dataChannelName = (String)postOfficeConfig.getAttributeValue("DataChannelName");
-
+         
          if (dataChannelName == null)
          {
             throw new IllegalStateException("Cannot find DataChannelName");
          }
 
+         if (node > 0)
+         {
+            dataChannelName += "_" + node;
+         }
+
          try
          {
             if(mbeanServer.getMBeanInfo(channelFactoryName) != null)




More information about the jboss-cvs-commits mailing list