You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ru...@apache.org on 2010/09/22 19:12:49 UTC
svn commit: r1000093 -
/synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java
Author: ruwan
Date: Wed Sep 22 17:12:49 2010
New Revision: 1000093
URL: http://svn.apache.org/viewvc?rev=1000093&view=rev
Log:
back porting the axis2 clustering API changes
Modified:
synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java
Modified: synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java
URL: http://svn.apache.org/viewvc/synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java?rev=1000093&r1=1000092&r2=1000093&view=diff
==============================================================================
--- synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java (original)
+++ synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java Wed Sep 22 17:12:49 2010
@@ -19,20 +19,18 @@
package org.apache.synapse.mediators.throttle;
import org.apache.axiom.om.OMElement;
+import org.apache.axis2.clustering.ClusterManager;
import org.apache.axis2.clustering.ClusteringFault;
-
-import org.apache.axis2.clustering.ClusteringAgent;
-import org.apache.axis2.clustering.state.Replicator;
-
+import org.apache.axis2.clustering.context.Replicator;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.neethi.PolicyEngine;
+import org.apache.synapse.ManagedLifecycle;
import org.apache.synapse.Mediator;
import org.apache.synapse.MessageContext;
-import org.apache.synapse.ManagedLifecycle;
import org.apache.synapse.SynapseLog;
import org.apache.synapse.config.Entry;
-import org.apache.synapse.core.axis2.Axis2MessageContext;
import org.apache.synapse.core.SynapseEnvironment;
+import org.apache.synapse.core.axis2.Axis2MessageContext;
import org.apache.synapse.mediators.AbstractMediator;
import org.apache.synapse.transport.nhttp.NhttpConstants;
import org.wso2.throttle.*;
@@ -121,9 +119,9 @@ public class ThrottleMediator extends Ab
//To ensure check for clustering environment only happens one time
if ((throttle == null && !isResponse) || (isResponse
&& concurrentAccessController == null)) {
- ClusteringAgent clusteringAgent = cc.getAxisConfiguration().getClusteringAgent();
- if (clusteringAgent != null &&
- clusteringAgent.getStateManager() != null) {
+ ClusterManager clusterManager = cc.getAxisConfiguration().getClusterManager();
+ if (clusterManager != null &&
+ clusterManager.getContextManager() != null) {
isClusteringEnable = true;
}
}