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

[hiranya]

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