svn commit: r1094936 - /synapse/trunk/java/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java

[hi...@apache.org]

Author: hiranya
Date: Tue Apr 19 08:51:54 2011
New Revision: 1094936

URL: http://svn.apache.org/viewvc?rev=1094936&view=rev
Log:
Fixing CARBON-8607, Axis2 server clustering issue

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

Modified: synapse/trunk/java/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java?rev=1094936&r1=1094935&r2=1094936&view=diff
==============================================================================
--- synapse/trunk/java/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java (original)
+++ synapse/trunk/java/modules/samples/src/main/java/samples/util/SampleAxis2ServerManager.java Tue Apr 19 08:51:54 2011
@@ -18,6 +18,7 @@
  */
 package samples.util;
 
+import org.apache.axis2.clustering.ClusteringAgent;
 import org.apache.axis2.context.ConfigurationContext;
 import org.apache.axis2.context.ConfigurationContextFactory;
 import org.apache.axis2.description.TransportInDescription;
@@ -41,7 +42,7 @@ public class SampleAxis2ServerManager {
 
     public static final int DEFAULT_PORT = 9000;
 
-    private ConfigurationContext configctx;
+    private ConfigurationContext configCtx;
     
     private ListenerManager listenerManager;
 
@@ -89,26 +90,27 @@ public class SampleAxis2ServerManager {
                     + new File(confLocation).getAbsolutePath());
         }
         try {
-            configctx = ConfigurationContextFactory
+            configCtx = ConfigurationContextFactory
                 .createConfigurationContextFromFileSystem(repoLocation,
                     confLocation);
 
-            configurePort(configctx);
+            configurePort(configCtx);
+
+            // Start the transport listeners
+            listenerManager = new ListenerManager();
+            listenerManager.init(configCtx);
+            listenerManager.start();
 
             // 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();
+            ClusteringAgent clusteringAgent =
+                    configCtx.getAxisConfiguration().getClusteringAgent();
             if(clusteringAgent != null) {
-                clusteringAgent.setConfigurationContext(configctx);
+                clusteringAgent.setConfigurationContext(configCtx);
                 clusteringAgent.init();
-            }*/
+            }
 
-            // Finally start the transport listeners
-            listenerManager = new ListenerManager();
-            listenerManager.init(configctx);
-            listenerManager.start();
             log.info("[SimpleAxisServer] Started");
         } catch (Throwable t) {
             log.fatal("[SimpleAxisServer] Shutting down. Error starting SimpleAxisServer", t);
@@ -122,8 +124,8 @@ public class SampleAxis2ServerManager {
             listenerManager.destroy();
         }
         //we need to call this method to clean the team fils we created.
-        if (configctx != null) {
-            configctx.terminate();
+        if (configCtx != null) {
+            configCtx.terminate();
         }
     }