[hornetq-commits] JBoss hornetq SVN: r9420 - in branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster: server0 and 6 other directories.

Author: jmesnil Date: 2010-07-19 10:28:26 -0400 (Mon, 19 Jul 2010) New Revision: 9420 Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/readme.html branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server0/hornetq-configuration.xml branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server1/hornetq-configuration.xml branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server2/hornetq-configuration.xml branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server3/hornetq-configuration.xml branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server4/hornetq-configuration.xml branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server5/hornetq-configuration.xml branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java Log: HA refactoring * fix JMS Symmetric Cluster example to use HA API and configuration Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/readme.html =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/readme.html 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/readme.html 2010-07-19 14:28:26 UTC (rev 9420) @@ -32,6 +32,7 @@ <code> &lt;cluster-connection name="my-cluster"&gt; &lt;address&gt;jms&lt;/address&gt; + &lt;connector-ref>netty-connector&lt;/connector-ref> &lt;retry-interval&gt;500&lt;/retry-interval&gt; &lt;use-duplicate-detection&gt;true&lt;/use-duplicate-detection&gt; &lt;forward-when-no-consumers&gt;true&lt;/forward-when-no-consumers&gt; @@ -62,7 +63,7 @@ <pre class="prettyprint"> <code> - ConnectionFactory cf = HornetQJMSClient.createConnectionFactory("231.7.7.7", 9876); + ConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithHA("231.7.7.7", 9876); </code> </pre> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server0/hornetq-configuration.xml =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server0/hornetq-configuration.xml 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server0/hornetq-configuration.xml 2010-07-19 14:28:26 UTC (rev 9420) @@ -29,7 +29,7 @@ <group-address>231.7.7.7</group-address> <group-port>9876</group-port> <broadcast-period>100</broadcast-period> - <connector-ref connector-name="netty-connector"/> + <connector-ref>netty-connector</connector-ref> </broadcast-group> </broadcast-groups> @@ -44,6 +44,7 @@ <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> + <connector-ref>netty-connector</connector-ref> <retry-interval>500</retry-interval> <use-duplicate-detection>true</use-duplicate-detection> <forward-when-no-consumers>false</forward-when-no-consumers> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server1/hornetq-configuration.xml =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server1/hornetq-configuration.xml 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server1/hornetq-configuration.xml 2010-07-19 14:28:26 UTC (rev 9420) @@ -27,7 +27,7 @@ <group-address>231.7.7.7</group-address> <group-port>9876</group-port> <broadcast-period>100</broadcast-period> - <connector-ref connector-name="netty-connector" /> + <connector-ref>netty-connector</connector-ref> </broadcast-group> </broadcast-groups> @@ -42,6 +42,7 @@ <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> + <connector-ref>netty-connector</connector-ref> <retry-interval>500</retry-interval> <use-duplicate-detection>true</use-duplicate-detection> <forward-when-no-consumers>false</forward-when-no-consumers> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server2/hornetq-configuration.xml =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server2/hornetq-configuration.xml 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server2/hornetq-configuration.xml 2010-07-19 14:28:26 UTC (rev 9420) @@ -27,7 +27,7 @@ <group-address>231.7.7.7</group-address> <group-port>9876</group-port> <broadcast-period>100</broadcast-period> - <connector-ref connector-name="netty-connector"/> + <connector-ref>netty-connector</connector-ref> </broadcast-group> </broadcast-groups> @@ -42,6 +42,7 @@ <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> + <connector-ref>netty-connector</connector-ref> <retry-interval>500</retry-interval> <use-duplicate-detection>true</use-duplicate-detection> <forward-when-no-consumers>false</forward-when-no-consumers> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server3/hornetq-configuration.xml =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server3/hornetq-configuration.xml 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server3/hornetq-configuration.xml 2010-07-19 14:28:26 UTC (rev 9420) @@ -27,7 +27,7 @@ <group-address>231.7.7.7</group-address> <group-port>9876</group-port> <broadcast-period>100</broadcast-period> - <connector-ref connector-name="netty-connector"/> + <connector-ref>netty-connector</connector-ref> </broadcast-group> </broadcast-groups> @@ -42,6 +42,7 @@ <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> + <connector-ref>netty-connector</connector-ref> <retry-interval>500</retry-interval> <use-duplicate-detection>true</use-duplicate-detection> <forward-when-no-consumers>false</forward-when-no-consumers> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server4/hornetq-configuration.xml =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server4/hornetq-configuration.xml 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server4/hornetq-configuration.xml 2010-07-19 14:28:26 UTC (rev 9420) @@ -26,7 +26,7 @@ <group-address>231.7.7.7</group-address> <group-port>9876</group-port> <broadcast-period>100</broadcast-period> - <connector-ref connector-name="netty-connector"/> + <connector-ref>netty-connector</connector-ref> </broadcast-group> </broadcast-groups> @@ -41,6 +41,7 @@ <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> + <connector-ref>netty-connector</connector-ref> <retry-interval>500</retry-interval> <use-duplicate-detection>true</use-duplicate-detection> <forward-when-no-consumers>false</forward-when-no-consumers> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server5/hornetq-configuration.xml =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server5/hornetq-configuration.xml 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/server5/hornetq-configuration.xml 2010-07-19 14:28:26 UTC (rev 9420) @@ -26,7 +26,7 @@ <group-address>231.7.7.7</group-address> <group-port>9876</group-port> <broadcast-period>100</broadcast-period> - <connector-ref connector-name="netty-connector"/> + <connector-ref>netty-connector</connector-ref> </broadcast-group> </broadcast-groups> @@ -41,6 +41,7 @@ <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> + <connector-ref>netty-connector</connector-ref> <retry-interval>500</retry-interval> <use-duplicate-detection>true</use-duplicate-detection> <forward-when-no-consumers>false</forward-when-no-consumers> Modified: branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java =================================================================== --- branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java 2010-07-19 14:27:00 UTC (rev 9419) +++ branches/2_2_0_HA_Improvements/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java 2010-07-19 14:28:26 UTC (rev 9420) @@ -79,7 +79,7 @@ // connection factory directly we avoid having to worry about a JNDI look-up. // In an app server environment you could use HA-JNDI to lookup from the clustered JNDI servers without // having to know about a specific one. - ConnectionFactory cf = HornetQJMSClient.createConnectionFactory("231.7.7.7", 9876); + ConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithHA("231.7.7.7", 9876); // We give a little while for each server to broadcast its whereabouts to the client Thread.sleep(2000);