Author: azeez
Date: Mon Jan 7 05:24:29 2008
New Revision: 11964
Log:
Handling synchrinization of nodes - made it optional
Modified:
trunk/wsas/java/modules/core/conf/axis2.xml
trunk/wsas/java/modules/core/src/org/wso2/wsas/ServerStatus.java
trunk/wsas/java/modules/core/src/org/wso2/wsas/util/ClusteringUtil.java
Modified: trunk/wsas/java/modules/core/conf/axis2.xml
==============================================================================
--- trunk/wsas/java/modules/core/conf/axis2.xml (original)
+++ trunk/wsas/java/modules/core/conf/axis2.xml Mon Jan 7 05:24:29 2008
@@ -400,6 +400,7 @@
<cluster class="org.apache.axis2.clustering.tribes.TribesClusterManager">
<parameter name="AvoidInitiation">true</parameter>
<parameter name="domain">wso2wsas.domain</parameter>
+ <parameter name="synchronizeAll">true</parameter>
<configurationManager
class="org.wso2.wsas.clustering.configuration.WSASConfigurationManager">
<parameter name="CommitTimeout">20000</parameter>
Modified: trunk/wsas/java/modules/core/src/org/wso2/wsas/ServerStatus.java
==============================================================================
--- trunk/wsas/java/modules/core/src/org/wso2/wsas/ServerStatus.java
(original)
+++ trunk/wsas/java/modules/core/src/org/wso2/wsas/ServerStatus.java Mon Jan
7 05:24:29 2008
@@ -27,27 +27,28 @@
/**
* Server is running
*/
- private static final String STATUS_RUNNING = "RUNNING";
+ public static final String STATUS_RUNNING = "RUNNING";
/**
* Server has switched to maintenace mode
*/
- private static final String STATUS_IN_MAINTENANCE = "IN_MAINTENANCE";
+ public static final String STATUS_IN_MAINTENANCE = "IN_MAINTENANCE";
/**
* Server is restarting
*/
- private static final String STATUS_RESTARTING = "RESTARTING";
+ public static final String STATUS_RESTARTING = "RESTARTING";
/**
* Server is shutting down
*/
- private static final String STATUS_SHUTTING_DOWN = "SHUTTING_DOWN";
+ public static final String STATUS_SHUTTING_DOWN = "SHUTTING_DOWN";
/**
* The current status of this WSAS instance
*/
private static final String CURRENT_SERVER_STATUS =
"current.server.status";
+// private static final String CURRENT_SERVER_STATUS =
"local_current.server.status";
private ServerStatus() {
}
Modified:
trunk/wsas/java/modules/core/src/org/wso2/wsas/util/ClusteringUtil.java
==============================================================================
--- trunk/wsas/java/modules/core/src/org/wso2/wsas/util/ClusteringUtil.java
(original)
+++ trunk/wsas/java/modules/core/src/org/wso2/wsas/util/ClusteringUtil.java
Mon Jan 7 05:24:29 2008
@@ -44,9 +44,9 @@
AxisConfiguration axisConfig = configContext.getAxisConfiguration();
ClusterManager clusterManager = axisConfig.getClusterManager();
if (clusterManager != null) {
+ clusterManager.setConfigurationContext(configContext);
if (!isClusterManagerInitialized) {
- clusterManager.setConfigurationContext(configContext);
clusterManager.init();
isClusterManagerInitialized = true;
}
@@ -85,6 +85,9 @@
axisConfig.addService(nodeManagerService);
}
}
+
+ configContext.
+
setNonReplicableProperty(ClusteringConstants.CLUSTER_INITIALIZED, "true");
}
}
}
_______________________________________________
Wsas-java-dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/wsas-java-dev
