svn commit: r1000093 - /synapse/branches/2.0/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java

[ruwan]

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;
                 }
             }