This commit is contained in:
Clebert Suconic 2017-08-25 22:46:13 -04:00
commit 035890e2ab
3 changed files with 119 additions and 124 deletions
examples/features/clustered/clustered-jgroups/src/main/resources/activemq
tests/integration-tests/src/test/resources

View File

@ -1,43 +1,43 @@
<?xml version='1.0'?>
<!-- <!--
Licensed to the Apache Software Foundation (ASF) under one Licensed to the Apache Software Foundation (ASF) under one or more
or more contributor license agreements. See the NOTICE file contributor license agreements. See the NOTICE file distributed with
distributed with this work for additional information this work for additional information regarding copyright ownership.
regarding copyright ownership. The ASF licenses this file The ASF licenses this file to You under the Apache License, Version 2.0
to you under the Apache License, Version 2.0 (the (the "License"); you may not use this file except in compliance with
"License"); you may not use this file except in compliance the License. You may obtain a copy of the License at
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0 http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, Unless required by applicable law or agreed to in writing, software
software distributed under the License is distributed on an distributed under the License is distributed on an "AS IS" BASIS,
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
KIND, either express or implied. See the License for the See the License for the specific language governing permissions and
specific language governing permissions and limitations limitations under the License.
under the License.
--> -->
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
<config xmlns="urn:org:jgroups" xmlns="urn:org:jgroups"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups.xsd">
xsi:schemaLocation="urn:org:jgroups file:schema/JGroups-2.8.xsd">
<TCP loopback="true" <TCP loopback="true"
recv_buf_size="20000000" recv_buf_size="${tcp.recv_buf_size:5M}"
send_buf_size="640000" send_buf_size="${tcp.send_buf_size:5M}"
discard_incompatible_packets="true" max_bundle_size="64K"
max_bundle_size="64000"
max_bundle_timeout="30" max_bundle_timeout="30"
enable_bundling="true" use_send_queues="true"
use_send_queues="false"
sock_conn_timeout="300" sock_conn_timeout="300"
timer_type="new3"
timer.min_threads="4"
timer.max_threads="10"
timer.keep_alive_time="3000"
timer.queue_max_size="500"
thread_pool.enabled="true" thread_pool.enabled="true"
thread_pool.min_threads="1" thread_pool.min_threads="2"
thread_pool.max_threads="10" thread_pool.max_threads="8"
thread_pool.keep_alive_time="5000" thread_pool.keep_alive_time="5000"
thread_pool.queue_enabled="false" thread_pool.queue_enabled="true"
thread_pool.queue_max_size="100" thread_pool.queue_max_size="10000"
thread_pool.rejection_policy="run" thread_pool.rejection_policy="discard"
oob_thread_pool.enabled="true" oob_thread_pool.enabled="true"
oob_thread_pool.min_threads="1" oob_thread_pool.min_threads="1"
@ -45,29 +45,26 @@ under the License.
oob_thread_pool.keep_alive_time="5000" oob_thread_pool.keep_alive_time="5000"
oob_thread_pool.queue_enabled="false" oob_thread_pool.queue_enabled="false"
oob_thread_pool.queue_max_size="100" oob_thread_pool.queue_max_size="100"
oob_thread_pool.rejection_policy="run"/> oob_thread_pool.rejection_policy="discard"/>
<!-- a location that can be found by both server's running --> <!-- a location that can be found by both server's running -->
<FILE_PING location="../../file.ping.dir"/> <FILE_PING location="../../file.ping.dir"/>
<MERGE2 max_interval="30000" <MERGE3 min_interval="10000"
min_interval="10000"/> max_interval="30000"/>
<FD_SOCK/> <FD_SOCK/>
<FD timeout="10000" max_tries="5" /> <FD timeout="3000" max_tries="3" />
<VERIFY_SUSPECT timeout="1500" /> <VERIFY_SUSPECT timeout="1500" />
<BARRIER /> <BARRIER />
<pbcast.NAKACK <pbcast.NAKACK2 use_mcast_xmit="false"
use_mcast_xmit="false" discard_delivered_msgs="true"/>
retransmit_timeout="300,600,1200,2400,4800" <UNICAST3 />
discard_delivered_msgs="true"/>
<UNICAST timeout="300,600,1200" />
<pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000" <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
max_bytes="400000"/> max_bytes="4M"/>
<pbcast.GMS print_local_addr="true" join_timeout="3000" <pbcast.GMS print_local_addr="true" join_timeout="2000"
view_bundling="true"/> view_bundling="true"/>
<FC max_credits="2000000" <MFC max_credits="2M"
min_threshold="0.10"/> min_threshold="0.4"/>
<FRAG2 frag_size="60000" /> <FRAG2 frag_size="60K" />
<!--RSVP resend_interval="2000" timeout="10000"/-->
<pbcast.STATE_TRANSFER/> <pbcast.STATE_TRANSFER/>
<pbcast.FLUSH timeout="0"/> </config>
</config>

View File

@ -1,43 +1,43 @@
<?xml version='1.0'?>
<!-- <!--
Licensed to the Apache Software Foundation (ASF) under one Licensed to the Apache Software Foundation (ASF) under one or more
or more contributor license agreements. See the NOTICE file contributor license agreements. See the NOTICE file distributed with
distributed with this work for additional information this work for additional information regarding copyright ownership.
regarding copyright ownership. The ASF licenses this file The ASF licenses this file to You under the Apache License, Version 2.0
to you under the Apache License, Version 2.0 (the (the "License"); you may not use this file except in compliance with
"License"); you may not use this file except in compliance the License. You may obtain a copy of the License at
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0 http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, Unless required by applicable law or agreed to in writing, software
software distributed under the License is distributed on an distributed under the License is distributed on an "AS IS" BASIS,
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
KIND, either express or implied. See the License for the See the License for the specific language governing permissions and
specific language governing permissions and limitations limitations under the License.
under the License.
--> -->
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
<config xmlns="urn:org:jgroups" xmlns="urn:org:jgroups"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups.xsd">
xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/JGroups-3.0.xsd">
<TCP loopback="true" <TCP loopback="true"
recv_buf_size="20000000" recv_buf_size="${tcp.recv_buf_size:5M}"
send_buf_size="640000" send_buf_size="${tcp.send_buf_size:5M}"
discard_incompatible_packets="true" max_bundle_size="64K"
max_bundle_size="64000"
max_bundle_timeout="30" max_bundle_timeout="30"
enable_bundling="true" use_send_queues="true"
use_send_queues="false"
sock_conn_timeout="300" sock_conn_timeout="300"
timer_type="new3"
timer.min_threads="4"
timer.max_threads="10"
timer.keep_alive_time="3000"
timer.queue_max_size="500"
thread_pool.enabled="true" thread_pool.enabled="true"
thread_pool.min_threads="1" thread_pool.min_threads="2"
thread_pool.max_threads="10" thread_pool.max_threads="8"
thread_pool.keep_alive_time="5000" thread_pool.keep_alive_time="5000"
thread_pool.queue_enabled="false" thread_pool.queue_enabled="true"
thread_pool.queue_max_size="100" thread_pool.queue_max_size="10000"
thread_pool.rejection_policy="run" thread_pool.rejection_policy="discard"
oob_thread_pool.enabled="true" oob_thread_pool.enabled="true"
oob_thread_pool.min_threads="1" oob_thread_pool.min_threads="1"
@ -45,29 +45,26 @@ under the License.
oob_thread_pool.keep_alive_time="5000" oob_thread_pool.keep_alive_time="5000"
oob_thread_pool.queue_enabled="false" oob_thread_pool.queue_enabled="false"
oob_thread_pool.queue_max_size="100" oob_thread_pool.queue_max_size="100"
oob_thread_pool.rejection_policy="run"/> oob_thread_pool.rejection_policy="discard"/>
<!-- a location that can be found by both server's running --> <!-- a location that can be found by both server's running -->
<FILE_PING location="../../file.ping.dir"/> <FILE_PING location="../../file.ping.dir"/>
<MERGE2 max_interval="30000" <MERGE3 min_interval="10000"
min_interval="10000"/> max_interval="30000"/>
<FD_SOCK/> <FD_SOCK/>
<FD timeout="10000" max_tries="5" /> <FD timeout="3000" max_tries="3" />
<VERIFY_SUSPECT timeout="1500" /> <VERIFY_SUSPECT timeout="1500" />
<BARRIER /> <BARRIER />
<pbcast.NAKACK <pbcast.NAKACK2 use_mcast_xmit="false"
use_mcast_xmit="false" discard_delivered_msgs="true"/>
retransmit_timeout="300,600,1200,2400,4800" <UNICAST3 />
discard_delivered_msgs="true"/>
<UNICAST timeout="300,600,1200" />
<pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000" <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
max_bytes="400000"/> max_bytes="4M"/>
<pbcast.GMS print_local_addr="true" join_timeout="3000" <pbcast.GMS print_local_addr="true" join_timeout="2000"
view_bundling="true"/> view_bundling="true"/>
<FC max_credits="2000000" <MFC max_credits="2M"
min_threshold="0.10"/> min_threshold="0.4"/>
<FRAG2 frag_size="60000" /> <FRAG2 frag_size="60K" />
<!--RSVP resend_interval="2000" timeout="10000"/-->
<pbcast.STATE_TRANSFER/> <pbcast.STATE_TRANSFER/>
<pbcast.FLUSH timeout="0"/> </config>
</config>

View File

@ -14,26 +14,30 @@
See the License for the specific language governing permissions and See the License for the specific language governing permissions and
limitations under the License. limitations under the License.
--> -->
<config xmlns="urn:org:jgroups" <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:org:jgroups"
xsi:schemaLocation="urn:org:jgroups file:schema/JGroups-2.8.xsd"> xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups.xsd">
<TCP loopback="true" <TCP loopback="true"
recv_buf_size="20000000" recv_buf_size="${tcp.recv_buf_size:5M}"
send_buf_size="640000" send_buf_size="${tcp.send_buf_size:5M}"
discard_incompatible_packets="true" max_bundle_size="64K"
max_bundle_size="64000"
max_bundle_timeout="30" max_bundle_timeout="30"
enable_bundling="true" use_send_queues="true"
use_send_queues="false"
sock_conn_timeout="300" sock_conn_timeout="300"
timer_type="new3"
timer.min_threads="4"
timer.max_threads="10"
timer.keep_alive_time="3000"
timer.queue_max_size="500"
thread_pool.enabled="true" thread_pool.enabled="true"
thread_pool.min_threads="1" thread_pool.min_threads="2"
thread_pool.max_threads="10" thread_pool.max_threads="8"
thread_pool.keep_alive_time="5000" thread_pool.keep_alive_time="5000"
thread_pool.queue_enabled="false" thread_pool.queue_enabled="true"
thread_pool.queue_max_size="100" thread_pool.queue_max_size="10000"
thread_pool.rejection_policy="run" thread_pool.rejection_policy="discard"
oob_thread_pool.enabled="true" oob_thread_pool.enabled="true"
oob_thread_pool.min_threads="1" oob_thread_pool.min_threads="1"
@ -41,28 +45,25 @@
oob_thread_pool.keep_alive_time="5000" oob_thread_pool.keep_alive_time="5000"
oob_thread_pool.queue_enabled="false" oob_thread_pool.queue_enabled="false"
oob_thread_pool.queue_max_size="100" oob_thread_pool.queue_max_size="100"
oob_thread_pool.rejection_policy="run"/> oob_thread_pool.rejection_policy="discard"/>
<FILE_PING location="./target/tmp/amqtest.ping.dir"/> <FILE_PING location="./target/tmp/amqtest.ping.dir"/>
<MERGE2 max_interval="30000" <MERGE3 min_interval="10000"
min_interval="10000"/> max_interval="30000"/>
<FD_SOCK/> <FD_SOCK/>
<FD timeout="10000" max_tries="5" /> <FD timeout="3000" max_tries="3" />
<VERIFY_SUSPECT timeout="1500" /> <VERIFY_SUSPECT timeout="1500" />
<BARRIER /> <BARRIER />
<pbcast.NAKACK <pbcast.NAKACK2 use_mcast_xmit="false"
use_mcast_xmit="false" discard_delivered_msgs="true"/>
retransmit_timeout="300,600,1200,2400,4800" <UNICAST3 />
discard_delivered_msgs="true"/>
<UNICAST timeout="300,600,1200" />
<pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000" <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
max_bytes="400000"/> max_bytes="4M"/>
<pbcast.GMS print_local_addr="true" join_timeout="3000" <pbcast.GMS print_local_addr="true" join_timeout="2000"
view_bundling="true"/> view_bundling="true"/>
<FC max_credits="2000000" <MFC max_credits="2M"
min_threshold="0.10"/> min_threshold="0.4"/>
<FRAG2 frag_size="60000" /> <FRAG2 frag_size="60K" />
<!--RSVP resend_interval="2000" timeout="10000"/-->
<pbcast.STATE_TRANSFER/> <pbcast.STATE_TRANSFER/>
<pbcast.FLUSH timeout="0"/> </config>
</config>