svn commit: r1001154 - /synapse/branches/2.0/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java

[hi...@apache.org]

Author: hiranya
Date: Sat Sep 25 07:35:06 2010
New Revision: 1001154

URL: http://svn.apache.org/viewvc?rev=1001154&view=rev
Log:
Fixing a clustering issue in the sample Axis2 server (required for dynamic load balancer samples)

- I'm not going to check this into the trunk since the clustering API may have changed in the Axis2 trunk


Modified:
    synapse/branches/2.0/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java

Modified: synapse/branches/2.0/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java
URL: http://svn.apache.org/viewvc/synapse/branches/2.0/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java?rev=1001154&r1=1001153&r2=1001154&view=diff
==============================================================================
--- synapse/branches/2.0/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java (original)
+++ synapse/branches/2.0/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java Sat Sep 25 07:35:06 2010
@@ -25,6 +25,7 @@ import org.apache.axis2.engine.ListenerM
 import org.apache.axis2.util.CommandLineOption;
 import org.apache.axis2.util.CommandLineOptionParser;
 import org.apache.axis2.util.OptionsValidator;
+import org.apache.axis2.clustering.ClusterManager;
 //import org.apache.axis2.clustering.ClusteringAgent;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -98,12 +99,12 @@ public class SampleAxis2ServerManager {
             // Need to initialize the cluster manager at last since we are changing the servers
             // HTTP/S ports above. In the axis2.xml file, we need to set the "AvoidInitiation" param
             // to "true"
-            /*ClusteringAgent clusteringAgent =
-                    configctx.getAxisConfiguration().getClusteringAgent();
-            if(clusteringAgent != null) {
-                clusteringAgent.setConfigurationContext(configctx);
-                clusteringAgent.init();
-            }*/
+            ClusterManager clusterManager =
+                    configctx.getAxisConfiguration().getClusterManager();
+            if (clusterManager != null) {
+                clusterManager.setConfigurationContext(configctx);
+                clusterManager.init();
+            }            
 
             // Finally start the transport listeners
             listenerManager = new ListenerManager();