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

do-not-reply at jboss.org do-not-reply at jboss.org
Mon Jul 19 10:28:27 EDT 2010 

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);

More information about the hornetq-commits mailing list