[wsas-java-dev] svn commit r1785 - in trunk/wsas/java/modules: clustering/src/org/wso2/wsas/clustering servlet-edition/conf standalone-edition/conf

svn at wso2.org svn at wso2.org
Fri Apr 6 03:26:00 PDT 2007


Author: azeez
Date: Fri Apr  6 03:25:42 2007
New Revision: 1785

Modified:
   trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManager.java
   trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/WSASConfigManagerListener.java
   trunk/wsas/java/modules/servlet-edition/conf/axis2.xml
   trunk/wsas/java/modules/standalone-edition/conf/axis2.xml
Log:
Removing all locked attributes in the axis2.xml & adding some config manager parameters
Code changes to accomodate API changes in axis2 clustering



Modified: trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManager.java
==============================================================================
--- trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManager.java	(original)
+++ trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManager.java	Fri Apr  6 03:25:42 2007
@@ -16,6 +16,7 @@
 package org.wso2.wsas.clustering;
 
 import org.apache.axis2.AxisFault;
+import org.apache.axis2.engine.AxisConfiguration;
 import org.apache.axis2.cluster.ClusterManager;
 import org.apache.axis2.cluster.configuration.ConfigurationManager;
 import org.apache.axis2.context.ConfigurationContext;
@@ -35,8 +36,9 @@
     private static final String CLUSTER_MANAGER_NULL =
             "ClusterManager is null. Please properly set the 'cluster' element in the axis2.xml file";
     public static final String OPERATION_FAILED = "nodemanager.operation.failed";
+    private static final int DEFAULT_NOTIFICATION_WAIT_TIME = 2000;
 
-    public boolean loadServiceGroup(String serviceGroupName) throws AxisFault {
+    /* public boolean loadServiceGroup(String serviceGroupName) throws AxisFault {
         init();
         ConfigurationManager configMan = getConfigurationManager();
         if (configMan != null) {
@@ -62,7 +64,7 @@
             throw new AxisFault(CONFIG_MANAGER_NULL);
         }
         return true;
-    }
+    }*/
 
     public boolean unloadServiceGroups(String[] serviceGroupNames) throws AxisFault {
         init();
@@ -70,13 +72,8 @@
         if (configMan == null) {
             throw new AxisFault(CONFIG_MANAGER_NULL);
         }
-        for (int i = 0; i < serviceGroupNames.length; i++) {
-            configMan.unloadServiceGroup(serviceGroupNames[i]);
-            if (!isOperationSuccessful(configMan)) {
-                return false;
-            }
-        }
-        return true;
+        configMan.unloadServiceGroups(serviceGroupNames);
+        return isOperationSuccessful();
     }
 
     public boolean loadServiceGroups(String[] serviceGroupNames) throws AxisFault {
@@ -85,13 +82,8 @@
         if (configMan == null) {
             throw new AxisFault(CONFIG_MANAGER_NULL);
         }
-        for (int i = 0; i < serviceGroupNames.length; i++) {
-            configMan.loadServiceGroup(serviceGroupNames[i]);
-            if (!isOperationSuccessful(configMan)) {
-                return false;
-            }
-        }
-        return true;
+        configMan.loadServiceGroups(serviceGroupNames);
+        return isOperationSuccessful();
     }
 
     public boolean applyPolicy(String serviceName, String policyId) throws AxisFault {
@@ -99,7 +91,7 @@
         ConfigurationManager configMan = getConfigurationManager();
         if (configMan != null) {
 //            configMan.applyPolicy(serviceName, policyId);
-            if (!isOperationSuccessful(configMan)) {
+            if (!isOperationSuccessful()) {
                 return false;
             }
         } else {
@@ -113,7 +105,7 @@
         ConfigurationManager configMan = getConfigurationManager();
         if (configMan != null) {
             configMan.reloadConfiguration();
-            if (!isOperationSuccessful(configMan)) {
+            if (!isOperationSuccessful()) {
                 return false;
             }
         } else {
@@ -182,7 +174,7 @@
         }
     }
 
-    private boolean isOperationSuccessful(ConfigurationManager configMan) throws AxisFault {
+    private boolean isOperationSuccessful() throws AxisFault {
         delay(); // Wait for sometime, so that the failures on other nodes can be detected
         MessageContext msgCtx = MessageContext.getCurrentMessageContext();
         AxisService axisService = msgCtx.getAxisService();
@@ -228,7 +220,16 @@
 
     private void delay() {
         try {
-            Thread.sleep(2000);
+            AxisConfiguration axisConfig =
+                    MessageContext.getCurrentMessageContext().getRootContext().getAxisConfiguration();
+            Parameter parameter =
+                    axisConfig.getClusterManager().getConfigurationManager().
+                            getParameter("NotificationWaitTime");
+            long delay = DEFAULT_NOTIFICATION_WAIT_TIME;
+            if (parameter != null) {
+                delay = Long.parseLong((String) parameter.getValue());
+            }
+            Thread.sleep(delay);
         } catch (InterruptedException e) {
             log.error(e);
         }

Modified: trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/WSASConfigManagerListener.java
==============================================================================
--- trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/WSASConfigManagerListener.java	(original)
+++ trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/WSASConfigManagerListener.java	Fri Apr  6 03:25:42 2007
@@ -34,6 +34,7 @@
 import java.util.Iterator;
 import java.util.List;
 import java.util.Vector;
+import java.util.ArrayList;
 
 /**
  *
@@ -43,8 +44,8 @@
     private static Log log = LogFactory.getLog(WSASConfigManagerListener.class);
 
     private static final String LOAD_CONFIGURATION_EVENT = "LOAD_CONFIGURATION_EVENT";
-    private static final String LOAD_SERVICE_GROUP_EVENT = "LOAD_SERVICE_GROUP_EVENT";
-    private static final String UNLOAD_SERVICE_GROUP_EVENT = "UNLOAD_SERVICE_GROUP_EVENT";
+    private static final String LOAD_SERVICE_GROUPS_EVENT = "LOAD_SERVICE_GROUPS_EVENT";
+    private static final String UNLOAD_SERVICE_GROUPS_EVENT = "UNLOAD_SERVICE_GROUPS_EVENT";
     private static final String APPLY_POLICY_EVENT = "APPLY_POLICY_EVENT";
 
     private ConfigurationContext configurationContext;
@@ -69,10 +70,10 @@
 
     /**
      * The max waiting period(ms) after receiving a prepare.
-     * The system waits for COMMIT_TIMEOUT ms before reverting to the old configuration
+     * The system waits for DEFAULT_COMMIT_TIMEOUT ms before reverting to the old configuration
      * and continuing to service Web service requests
      */
-    private final int COMMIT_TIMEOUT = 20000;
+    private final int DEFAULT_COMMIT_TIMEOUT = 20000;
 
     /**
      * The time at which a prepare was received
@@ -80,52 +81,73 @@
     private long prepareReceivedTime;
 
 
-    public void serviceGroupLoaded(ConfigurationEvent configurationEvent) {
+    public void serviceGroupsLoaded(ConfigurationEvent configurationEvent) {
 
         // Set isProcessing to true so that, even if a prepare or commit is received
         // before this method is completed, the system will wait, until the reload is complete
         isProcessing = true;
 
-        String sgName = configurationEvent.getConfigurationName();
-        log.info("Going to load service group - " + sgName + " ...");
+        String[] sgNames = configurationEvent.getServiceGroupNames();
+        log.info("Going to load service groups...");
 
         AxisConfiguration axisConfig = configurationContext.getAxisConfiguration();
-        AxisServiceGroup serviceGroup = axisConfig.getServiceGroup(sgName);
-        if (serviceGroup == null) {  // New service group
+        boolean isOperationSuccessful = true;
+        List axisServiceGroups = new ArrayList();
+        for (int i = 0; i < sgNames.length; i++) {
+            String sgName = sgNames[i];
+            log.info("Going to load service groups - " + sgName + " ...");
+            AxisServiceGroup serviceGroup = axisConfig.getServiceGroup(sgName);
+            if (serviceGroup == null) {  // New service group
 //            DeploymentEngine.buildServiceGroup();
-            // TODO:
-            pendingCommits.add(new Commit(LOAD_SERVICE_GROUP_EVENT, serviceGroup));
-        } else { // Existing service group
-            //TODO
+                // TODO:
+            } else { // Existing service group
+                //TODO
+            }
+            axisServiceGroups.add(serviceGroup);
+        }
+
+        if (isOperationSuccessful) {
+            pendingCommits.add(new Commit(LOAD_SERVICE_GROUPS_EVENT, axisServiceGroups));
         }
 
         // We've finished processing this request, so reset the isProcessing flag to false
         isProcessing = false;
     }
 
-    public void serviceGroupUnloaded(ConfigurationEvent configurationEvent) {
+    public void serviceGroupsUnloaded(ConfigurationEvent configurationEvent) {
 
         // Set isProcessing to true so that, even if a prepare or commit is received
         // before this method is completed, the system will wait, until the reload is complete
         isProcessing = true;
-        String sgName = configurationEvent.getConfigurationName();
-        log.info("Going to unload service group - " + sgName + " ...");
+        String[] sgNames = configurationEvent.getServiceGroupNames();
+        log.info("Going to unload service groups...");
 
 
         AxisConfiguration axisConfig = configurationContext.getAxisConfiguration();
-        AxisServiceGroup serviceGroup = axisConfig.getServiceGroup(sgName);
-        if (serviceGroup == null) {
-            String msg = "Service group " + sgName + " does not exist";
-            log.info(msg);
-            try {
-                notifyFailureToNodeManager();
-                axisConfig.getClusterManager().getConfigurationManager().
-                        exceptionOccurred(new Exception(msg));
-            } catch (Exception e) {
-                log.error(e);
+        boolean isOperationSuccessful = true;
+        List axisServiceGroups = new ArrayList();
+        for (int i = 0; i < sgNames.length; i++) {
+            String sgName = sgNames[i];
+            AxisServiceGroup serviceGroup = axisConfig.getServiceGroup(sgName);
+
+            if (serviceGroup == null) {
+                isOperationSuccessful = false;
+                String msg = "Service group " + sgNames + " does not exist";
+                log.info(msg);
+                try {
+                    notifyFailureToNodeManager();
+                    axisConfig.getClusterManager().getConfigurationManager().
+                            exceptionOccurred(new Exception(msg));
+                } catch (Exception e) {
+                    log.error(e);
+                }
+                break;
+            } else {
+                axisServiceGroups.add(serviceGroup);
             }
-        } else {
-            pendingCommits.add(new Commit(UNLOAD_SERVICE_GROUP_EVENT, serviceGroup));
+        }
+        if (isOperationSuccessful) {
+            pendingCommits.add(new Commit(UNLOAD_SERVICE_GROUPS_EVENT, axisServiceGroups));
         }
 
         // We've finished processing this request, so reset the isProcessing flag to false
@@ -212,14 +234,20 @@
                         configurationContext.setProperty(ServerConstants.BLOCK_ALL_REQUESTS,
                                                          Boolean.TRUE);
                         break; // No need to continue since all requests are going to be blocked
-                    } else if (event.equals(LOAD_SERVICE_GROUP_EVENT)) {
-                        String sgName =
-                                ((AxisServiceGroup) commit.getObject()).getServiceGroupName();
-                        AxisServiceGroup serviceGroup =
-                                configurationContext.getAxisConfiguration().getServiceGroup(sgName);
-                        addBlockAllRequestsParameter(serviceGroup);
-                    } else if (event.equals(UNLOAD_SERVICE_GROUP_EVENT)) {
-                        addBlockAllRequestsParameter((AxisServiceGroup) commit.getObject());
+                    } else if (event.equals(LOAD_SERVICE_GROUPS_EVENT)) {
+                        List axisServiceGroups = (List) commit.getObject();
+                        for (Iterator iterator = axisServiceGroups.iterator();
+                             iterator.hasNext();) {
+                            AxisServiceGroup axisSG = (AxisServiceGroup) iterator.next();
+                            addBlockAllRequestsParameter(axisSG);
+                        }
+                    } else if (event.equals(UNLOAD_SERVICE_GROUPS_EVENT)) {
+                        List axisServiceGroups = (List) commit.getObject();
+                        for (Iterator iterator = axisServiceGroups.iterator();
+                             iterator.hasNext();) {
+                            AxisServiceGroup axisSG = (AxisServiceGroup) iterator.next();
+                            addBlockAllRequestsParameter(axisSG);
+                        }
                     } else if (event.equals(APPLY_POLICY_EVENT)) {
                         addBlockAllRequestsParameter((AxisServiceGroup) commit.getObject());
                     } else {
@@ -235,13 +263,21 @@
         // we need to discard what was done earlier and start serving requests
         Thread commitTimer = new Thread("CommitTimer") {
             public void run() {
+                AxisConfiguration axisConfig = configurationContext.getAxisConfiguration();
+                Parameter parameter =
+                        axisConfig.getClusterManager().getConfigurationManager().
+                                getParameter("CommitTimeout");
+                long timeOut = DEFAULT_COMMIT_TIMEOUT;
+                if (parameter != null) {
+                    timeOut = Long.parseLong((String) parameter.getValue());
+                }
                 while (!isCommitReceived) {
                     if (prepareReceivedTime != 0 &&
-                        System.currentTimeMillis() - prepareReceivedTime > COMMIT_TIMEOUT) {
+                        System.currentTimeMillis() - prepareReceivedTime > timeOut) {
                         pendingCommits.clear();
                         configurationContext.getProperties().
                                 remove(ServerConstants.BLOCK_ALL_REQUESTS);
-                        log.info("Commit message not received within " + COMMIT_TIMEOUT +
+                        log.info("Commit message not received within " + timeOut +
                                  " ms. Resuming operations.");
                         try {
                             reinitialize();
@@ -327,15 +363,18 @@
                         } catch (Exception e) {
                             log.error("Cannot commit " + LOAD_CONFIGURATION_EVENT, e);
                         }
-                    } else if (event.equals(LOAD_SERVICE_GROUP_EVENT)) {
+                    } else if (event.equals(LOAD_SERVICE_GROUPS_EVENT)) {
                         //TODO: impl
-                    } else if (event.equals(UNLOAD_SERVICE_GROUP_EVENT)) {
-                        AxisServiceGroup serviceGroup = (AxisServiceGroup) commit.getObject();
-                        try {
-                            configurationContext.getAxisConfiguration().
-                                    removeServiceGroup(serviceGroup.getServiceGroupName());
-                        } catch (Exception e) {
-                            log.error("Cannot commit " + UNLOAD_SERVICE_GROUP_EVENT, e);
+                    } else if (event.equals(UNLOAD_SERVICE_GROUPS_EVENT)) {
+                        List serviceGroups = (List) commit.getObject();
+                        for (Iterator sgIter = serviceGroups.iterator(); sgIter.hasNext();) {
+                            AxisServiceGroup serviceGroup = (AxisServiceGroup)sgIter.next();
+                            try {
+                                configurationContext.getAxisConfiguration().
+                                        removeServiceGroup(serviceGroup.getServiceGroupName());
+                            } catch (Exception e) {
+                                log.error("Cannot commit " + UNLOAD_SERVICE_GROUPS_EVENT, e);
+                            }
                         }
                     } else if (event.equals(APPLY_POLICY_EVENT)) {
                         //TODO: impl

Modified: trunk/wsas/java/modules/servlet-edition/conf/axis2.xml
==============================================================================
--- trunk/wsas/java/modules/servlet-edition/conf/axis2.xml	(original)
+++ trunk/wsas/java/modules/servlet-edition/conf/axis2.xml	Fri Apr  6 03:25:42 2007
@@ -9,16 +9,16 @@
     <!-- ================================================= -->
     <!-- Parameters -->
     <!-- ================================================= -->
-    <parameter name="hotdeployment" locked="false">true</parameter>
-    <parameter name="hotupdate" locked="false">false</parameter>
-    <parameter name="enableMTOM" locked="false">false</parameter>
-    <parameter name="cacheAttachments" locked="false">true</parameter>
-    <parameter name="attachmentDIR" locked="false">work/mtom</parameter>
-    <parameter name="sizeThreshold" locked="false">4000</parameter>
-    <parameter name="wso2wsf.tracer.trace.filter.impl" locked="false">
+    <parameter name="hotdeployment">true</parameter>
+    <parameter name="hotupdate">false</parameter>
+    <parameter name="enableMTOM">false</parameter>
+    <parameter name="cacheAttachments">true</parameter>
+    <parameter name="attachmentDIR">work/mtom</parameter>
+    <parameter name="sizeThreshold">4000</parameter>
+    <parameter name="wso2wsf.tracer.trace.filter.impl">
         org.wso2.wsas.util.TraceFilterImpl
     </parameter>
-    <parameter name="wso2wsf.tracer.trace.persister.impl" locked="false">
+    <parameter name="wso2wsf.tracer.trace.persister.impl">
         org.wso2.wsas.util.TracePersisterImpl
     </parameter>
 
@@ -27,9 +27,9 @@
 
     <!--During a fault, stacktrace can be sent with the fault message. The following flag will control -->
     <!--that behaviour.-->
-    <parameter name="sendStacktraceDetailsWithFaults" locked="false">true</parameter>
+    <parameter name="sendStacktraceDetailsWithFaults">true</parameter>
 
-    <parameter name="Sandesha2StorageManager" locked="false">inmemory</parameter>
+    <parameter name="Sandesha2StorageManager">inmemory</parameter>
 
     <!-- This deployment interceptor will be called whenever before a module is initialized or
      service is deployed -->
@@ -37,8 +37,8 @@
     <listener class="org.wso2.wsas.feed.FeedListener"/>
 
     <!-- setting contextRoot and servicePath-->
-    <parameter name="contextRoot" locked="false">/wso2wsas</parameter>
-    <parameter name="servicePath" locked="false">services</parameter>
+    <parameter name="contextRoot">/wso2wsas</parameter>
+    <parameter name="servicePath">services</parameter>
 
     <parameter name="userAgent"
                locked="true">WSO2 WSAS Servlet Edition v at wso2wsas_version@</parameter>
@@ -51,10 +51,10 @@
     <!--as the faultreason/Reason. But when a fault is thrown from a service or some where, it will be -->
     <!--wrapped by different levels. Due to this the initial exception message can be lost. If this flag-->
     <!--is set then, Axis2 tries to get the first exception and set its message as the faultreason/Reason.-->
-    <parameter name="DrillDownToRootCauseForFaultReason" locked="false">false</parameter>
+    <parameter name="DrillDownToRootCauseForFaultReason">false</parameter>
 
     <!--Set the flag to true if you want to enable transport level session mangment-->
-    <parameter name="manageTransportSession" locked="false">true</parameter>
+    <parameter name="manageTransportSession">true</parameter>
 
     <!-- ================================================= -->
     <!-- Message Formatter -->
@@ -105,7 +105,7 @@
     -->
     <!--transportReceiver name="mod_proxy/http"
                        class="org.wso2.utils.transport.http.GenericHttpTransportListener">
-        <parameter name="port" locked="false">80</parameter>
+        <parameter name="port">80</parameter>
     </transportReceiver-->
 
     <!--
@@ -114,7 +114,7 @@
     -->
     <!--transportReceiver name="mod_proxy/https"
                        class="rg.wso2.wsf.common.transport.http.GenericHttpsTransportListener">
-        <parameter name="port" locked="false">443</parameter>
+        <parameter name="port">443</parameter>
     </transportReceiver-->
 
     <!--
@@ -123,7 +123,7 @@
     -->
     <!--<transportReceiver name="tcp"
                        class="org.apache.axis2.transport.tcp.TCPServer">
-        <parameter name="port" locked="false">6667</parameter>
+        <parameter name="port">6667</parameter>
     </transportReceiver>-->
 
     <!--
@@ -132,7 +132,7 @@
     -->
     <!--<transportReceiver name="tcp"
                        class="org.apache.axis2.transport.tcp.TCPServer">
-        <parameter name="port" locked="false">6667</parameter>
+        <parameter name="port">6667</parameter>
     </transportReceiver>-->
 
     <!--
@@ -140,11 +140,11 @@
      parameters and uncomment the following
     -->
     <!--<transportReceiver name="mail" class="org.apache.axis2.transport.mail.SimpleMailListener">
-        <parameter name="mail.pop3.host" locked="false">localhost</parameter>
-        <parameter name="mail.pop3.user" locked="false">red</parameter>
-        <parameter name="mail.store.protocol" locked="false">pop3</parameter>
-        <parameter name="transport.mail.pop3.password" locked="false">red</parameter>
-        <parameter name="transport.mail.replyToAddress" locked="false">red at localhost</parameter>
+        <parameter name="mail.pop3.host">localhost</parameter>
+        <parameter name="mail.pop3.user">red</parameter>
+        <parameter name="mail.store.protocol">pop3</parameter>
+        <parameter name="transport.mail.pop3.password">red</parameter>
+        <parameter name="transport.mail.replyToAddress">red at localhost</parameter>
     </transportReceiver>-->
 
     <!--
@@ -152,22 +152,22 @@
       after setting up your JMS environment (e.g. ActiveMQ)
     -->
     <!--<transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener">
-        <parameter name="myTopicConnectionFactory" locked="false">
-        	<parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
-        	<parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter>
-        	<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">TopicConnectionFactory</parameter>
+        <parameter name="myTopicConnectionFactory">
+        	<parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
+        	<parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
+        	<parameter name="transport.jms.ConnectionFactoryJNDIName">TopicConnectionFactory</parameter>
         </parameter>
 
-        <parameter name="myQueueConnectionFactory" locked="false">
-        	<parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
-        	<parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter>
-        	<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
+        <parameter name="myQueueConnectionFactory">
+        	<parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
+        	<parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
+        	<parameter name="transport.jms.ConnectionFactoryJNDIName">QueueConnectionFactory</parameter>
         </parameter>
 
-        <parameter name="default" locked="false">
-        	<parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
-        	<parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter>
-        	<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
+        <parameter name="default">
+        	<parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
+        	<parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
+        	<parameter name="transport.jms.ConnectionFactoryJNDIName">QueueConnectionFactory</parameter>
         </parameter>
     </transportReceiver>-->
 
@@ -183,13 +183,13 @@
                      class="org.apache.axis2.transport.jms.JMSSender"/>
     <transportSender name="http"
                      class="org.apache.axis2.transport.http.CommonsHTTPTransportSender">
-        <parameter name="PROTOCOL" locked="false">HTTP/1.1</parameter>
-        <parameter name="Transfer-Encoding" locked="false">chunked</parameter>
+        <parameter name="PROTOCOL">HTTP/1.1</parameter>
+        <parameter name="Transfer-Encoding">chunked</parameter>
     </transportSender>
     <transportSender name="https"
                      class="org.apache.axis2.transport.http.CommonsHTTPTransportSender">
-        <parameter name="PROTOCOL" locked="false">HTTP/1.1</parameter>
-        <parameter name="Transfer-Encoding" locked="false">chunked</parameter>
+        <parameter name="PROTOCOL">HTTP/1.1</parameter>
+        <parameter name="Transfer-Encoding">chunked</parameter>
     </transportSender>
 
     <!-- ================================================= -->
@@ -284,4 +284,26 @@
         <phase name="PolicyDetermination"/>
         <phase name="MessageOut"/>
     </phaseOrder>
+
+    <!-- ================================================= -->
+    <!-- Clustering  -->
+    <!-- Configure and uncomment following for preparing Axis2 to a clustered environment -->
+    <!-- ================================================= -->
+    <!--
+    <cluster class="org.apache.axis2.cluster.tribes.TribesClusterManager">
+        <parameter name="AvoidInitiation">true</parameter>
+        <configurationManager class="org.apache.axis2.cluster.tribes.configuration.TribesConfigurationManager">
+            <parameter name="CommitTimeout">20000</parameter>
+            <parameter name="NotificationWaitTime">2000</parameter>
+            <listeners>
+                <listener class="org.wso2.wsas.clustering.WSASConfigManagerListener"/>
+            </listeners>
+        </configurationManager>
+        <contextManager class="org.apache.axis2.cluster.tribes.context.TribesContextManager">
+            <listeners>
+                <listener class="org.apache.axis2.cluster.listeners.DefaultContextManagerListener" />
+            </listeners>
+        </contextManager>
+    </cluster>
+    -->
 </axisconfig>
\ No newline at end of file

Modified: trunk/wsas/java/modules/standalone-edition/conf/axis2.xml
==============================================================================
--- trunk/wsas/java/modules/standalone-edition/conf/axis2.xml	(original)
+++ trunk/wsas/java/modules/standalone-edition/conf/axis2.xml	Fri Apr  6 03:25:42 2007
@@ -9,23 +9,23 @@
     <!-- ================================================= -->
     <!-- Parameters -->
     <!-- ================================================= -->
-    <parameter name="hotdeployment" locked="false">true</parameter>
-    <parameter name="hotupdate" locked="false">false</parameter>
-    <parameter name="enableMTOM" locked="false">false</parameter>
-    <parameter name="cacheAttachments" locked="false">true</parameter>
-    <parameter name="attachmentDIR" locked="false">work/mtom</parameter>
-    <parameter name="sizeThreshold" locked="false">4000</parameter>
-    <parameter name="wso2tracer.trace.filter.impl" locked="false">
+    <parameter name="hotdeployment">true</parameter>
+    <parameter name="hotupdate">false</parameter>
+    <parameter name="enableMTOM">false</parameter>
+    <parameter name="cacheAttachments">true</parameter>
+    <parameter name="attachmentDIR">work/mtom</parameter>
+    <parameter name="sizeThreshold">4000</parameter>
+    <parameter name="wso2tracer.trace.filter.impl">
         org.wso2.wsas.util.TraceFilterImpl
     </parameter>
-    <parameter name="wso2tracer.trace.persister.impl" locked="false">
+    <parameter name="wso2tracer.trace.persister.impl">
         org.wso2.wsas.util.TracePersisterImpl
     </parameter>
 
     <!-- Following parameter will completely disable REST handling in both the servlets-->
     <parameter name="disableREST" locked="true">false</parameter>
 
-    <parameter name="Sandesha2StorageManager" locked="false">inmemory</parameter>
+    <parameter name="Sandesha2StorageManager">inmemory</parameter>
 
     <!-- This deployment interceptor will be called whenever before a module is initialized or
      service is deployed -->
@@ -33,8 +33,8 @@
     <listener class="org.wso2.wsas.feed.FeedListener"/>
 
     <!-- setting contextPath and servicePath-->
-    <parameter name="contextRoot" locked="false">/</parameter>
-    <parameter name="servicePath" locked="false">services</parameter>
+    <parameter name="contextRoot">/</parameter>
+    <parameter name="servicePath">services</parameter>
 
     <parameter name="userAgent" locked="true">
         WSO2 WSAS for Java - Version @wso2wsas_version@
@@ -47,16 +47,16 @@
 
     <!--During a fault, stacktrace can be sent with the fault message. The following flag will control -->
     <!--that behaviour.-->
-    <parameter name="sendStacktraceDetailsWithFaults" locked="false">true</parameter>
+    <parameter name="sendStacktraceDetailsWithFaults">true</parameter>
 
     <!--If there aren't any information available to find out the fault reason, we set the message of the expcetion-->
     <!--as the faultreason/Reason. But when a fault is thrown from a service or some where, it will be -->
     <!--wrapped by different levels. Due to this the initial exception message can be lost. If this flag-->
     <!--is set then, Axis2 tries to get the first exception and set its message as the faultreason/Reason.-->
-    <parameter name="DrillDownToRootCauseForFaultReason" locked="false">true</parameter>
+    <parameter name="DrillDownToRootCauseForFaultReason">true</parameter>
 
     <!--Set the flag to true if you want to enable transport level session mangment-->
-    <parameter name="manageTransportSession" locked="false">true</parameter>
+    <parameter name="manageTransportSession">true</parameter>
 
     <!-- ================================================= -->
     <!-- Message Receivers -->
@@ -98,22 +98,22 @@
     <!-- ================================================= -->
     <transportReceiver name="http"
                        class="org.wso2.wsas.HttpTransportListener">
-        <parameter name="port" locked="false">9762</parameter>
+        <parameter name="port">9762</parameter>
     </transportReceiver>
 
     <transportReceiver name="https"
                        class="org.wso2.wsas.HttpsTransportListener">
-        <parameter name="port" locked="false">9443</parameter>
-        <parameter name="sslProtocol" locked="false">TLS</parameter>
-        <parameter name="maxHttpHeaderSize" locked="false">8192</parameter>
-        <parameter name="maxThreads" locked="false">150</parameter>
-        <parameter name="minSpareThreads" locked="false">25</parameter>
-        <parameter name="maxSpareThreads" locked="false">75</parameter>
-        <parameter name="enableLookups" locked="false">false</parameter>
-        <parameter name="disableUploadTimeout" locked="false">false</parameter>
-        <parameter name="clientAuth" locked="false">false</parameter>
-        <parameter name="acceptCount" locked="false">100</parameter>
-        <parameter name="keystore" locked="false">
+        <parameter name="port">9443</parameter>
+        <parameter name="sslProtocol">TLS</parameter>
+        <parameter name="maxHttpHeaderSize">8192</parameter>
+        <parameter name="maxThreads">150</parameter>
+        <parameter name="minSpareThreads">25</parameter>
+        <parameter name="maxSpareThreads">75</parameter>
+        <parameter name="enableLookups">false</parameter>
+        <parameter name="disableUploadTimeout">false</parameter>
+        <parameter name="clientAuth">false</parameter>
+        <parameter name="acceptCount">100</parameter>
+        <parameter name="keystore">
             <wso2wsas:KeyStore xmlns:wso2wsas="http://www.wso2.org/products/wsas">
                 <!-- Key store file location-->
                 <wso2wsas:Location>conf/wso2wsas.jks</wso2wsas:Location>
@@ -131,7 +131,7 @@
     -->
     <!--transportReceiver name="mod_proxy/http"
                        class="org.wso2.utils.transport.http.GenericHttpTransportListener">
-        <parameter name="port" locked="false">80</parameter>
+        <parameter name="port">80</parameter>
     </transportReceiver-->
 
     <!--
@@ -140,7 +140,7 @@
     -->
     <!--transportReceiver name="mod_proxy/https"
                        class="rg.wso2.wsf.common.transport.http.GenericHttpsTransportListener">
-        <parameter name="port" locked="false">443</parameter>
+        <parameter name="port">443</parameter>
     </transportReceiver-->
 
     <!--
@@ -149,7 +149,7 @@
     -->
     <!--<transportReceiver name="tcp"
                        class="org.apache.axis2.transport.tcp.TCPServer">
-        <parameter name="port" locked="false">6667</parameter>
+        <parameter name="port">6667</parameter>
     </transportReceiver>-->
 
     <!--
@@ -157,11 +157,11 @@
      parameters and uncomment the following
     -->
     <!--<transportReceiver name="mailto" class="org.apache.axis2.transport.mail.SimpleMailListener">
-        <parameter name="mail.pop3.host" locked="false">localhost</parameter>
-        <parameter name="mail.pop3.user" locked="false">red</parameter>
-        <parameter name="mail.store.protocol" locked="false">pop3</parameter>
-        <parameter name="transport.mail.pop3.password" locked="false">red</parameter>
-        <parameter name="transport.mail.replyToAddress" locked="false">red at localhost</parameter>
+        <parameter name="mail.pop3.host">localhost</parameter>
+        <parameter name="mail.pop3.user">red</parameter>
+        <parameter name="mail.store.protocol">pop3</parameter>
+        <parameter name="transport.mail.pop3.password">red</parameter>
+        <parameter name="transport.mail.replyToAddress">red at localhost</parameter>
         <parameter name="transport.listener.interval">3000</parameter>
     </transportReceiver>-->
 
@@ -170,22 +170,22 @@
       after setting up your JMS environment (e.g. ActiveMQ)
     -->
     <!--<transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener">
-        <parameter name="myTopicConnectionFactory" locked="false">
-        	<parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
-        	<parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter>
-        	<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">TopicConnectionFactory</parameter>
+        <parameter name="myTopicConnectionFactory">
+        	<parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
+        	<parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
+        	<parameter name="transport.jms.ConnectionFactoryJNDIName">TopicConnectionFactory</parameter>
         </parameter>
 
-        <parameter name="myQueueConnectionFactory" locked="false">
-        	<parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
-        	<parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter>
-        	<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
+        <parameter name="myQueueConnectionFactory">
+        	<parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
+        	<parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
+        	<parameter name="transport.jms.ConnectionFactoryJNDIName">QueueConnectionFactory</parameter>
         </parameter>
 
-        <parameter name="default" locked="false">
-        	<parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
-        	<parameter name="java.naming.provider.url" locked="false">tcp://localhost:61616</parameter>
-        	<parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
+        <parameter name="default">
+        	<parameter name="java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
+        	<parameter name="java.naming.provider.url">tcp://localhost:61616</parameter>
+        	<parameter name="transport.jms.ConnectionFactoryJNDIName">QueueConnectionFactory</parameter>
         </parameter>
     </transportReceiver>-->
 
@@ -201,17 +201,17 @@
                      class="org.apache.axis2.transport.jms.JMSSender"/>
     <transportSender name="http"
                      class="org.apache.axis2.transport.http.CommonsHTTPTransportSender">
-        <parameter name="PROTOCOL" locked="false">HTTP/1.1</parameter>
-        <parameter name="Transfer-Encoding" locked="false">chunked</parameter>
+        <parameter name="PROTOCOL">HTTP/1.1</parameter>
+        <parameter name="Transfer-Encoding">chunked</parameter>
     </transportSender>
     <transportSender name="https"
                      class="org.apache.axis2.transport.http.CommonsHTTPTransportSender">
-        <parameter name="PROTOCOL" locked="false">HTTP/1.1</parameter>
-        <parameter name="Transfer-Encoding" locked="false">chunked</parameter>
+        <parameter name="PROTOCOL">HTTP/1.1</parameter>
+        <parameter name="Transfer-Encoding">chunked</parameter>
     </transportSender>
 
     <!--<transportSender name="mailto" class="org.apache.axis2.transport.mail.MailTransportSender">
-        <parameter name="mail.smtp.host" locked="false">localhost</parameter>
+        <parameter name="mail.smtp.host">localhost</parameter>
     </transportSender>-->
 
     <!-- ================================================= -->
@@ -311,9 +311,12 @@
     <!-- Clustering  -->
     <!-- Configure and uncomment following for preparing Axis2 to a clustered environment -->    
     <!-- ================================================= -->
-    <!--<cluster class="org.apache.axis2.cluster.tribes.TribesClusterManager">
-        <parameter name="AvoidInitiation" locked="false">true</parameter>
+    <!--
+    <cluster class="org.apache.axis2.cluster.tribes.TribesClusterManager">
+        <parameter name="AvoidInitiation">true</parameter>
         <configurationManager class="org.apache.axis2.cluster.tribes.configuration.TribesConfigurationManager">
+            <parameter name="CommitTimeout">20000</parameter>
+            <parameter name="NotificationWaitTime">2000</parameter>
             <listeners>
                 <listener class="org.wso2.wsas.clustering.WSASConfigManagerListener"/>
             </listeners>
@@ -323,5 +326,6 @@
                 <listener class="org.apache.axis2.cluster.listeners.DefaultContextManagerListener" />
             </listeners>
         </contextManager>
-    </cluster>-->
+    </cluster>
+    -->
 </axisconfig>
\ No newline at end of file




More information about the Wsas-java-dev mailing list