svn commit: r592662 - /webservices/synapse/trunk/java/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java

[indika]

Author: indika
Date: Wed Nov  7 01:13:42 2007
New Revision: 592662

URL: http://svn.apache.org/viewvc?rev=592662&view=rev
Log:
fixed issue in SYNAPSE-173

Modified:
    
webservices/synapse/trunk/java/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java

Modified: 
webservices/synapse/trunk/java/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java
URL: 
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java?rev=592662&r1=592661&r2=592662&view=diff
==============================================================================
--- 
webservices/synapse/trunk/java/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java
 (original)
+++ 
webservices/synapse/trunk/java/modules/extensions/src/main/java/org/apache/synapse/mediators/throttle/ThrottleMediator.java
 Wed Nov  7 01:13:42 2007
@@ -22,6 +22,7 @@
 import org.apache.neethi.PolicyEngine;
 import org.apache.synapse.Mediator;
 import org.apache.synapse.MessageContext;
+import org.apache.synapse.SynapseException;
 import org.apache.synapse.config.Entry;
 import org.apache.synapse.core.axis2.Axis2MessageContext;
 import org.apache.synapse.mediators.AbstractMediator;
@@ -29,7 +30,6 @@
 import org.wso2.throttle.*;
 import org.wso2.throttle.factory.AccessControllerFactory;
 
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -65,6 +65,19 @@
     private boolean includesIPThrottling = false;
     /** The concurrent connection limit */
     private int concurrentLimit;
+    /** Access rate controller*/
+    private AccessController accessControler;
+
+    public ThrottleMediator() {
+        try {
+            this.accessControler =
+                
AccessControllerFactory.createAccessControler(ThrottleConstants.IP_BASE);
+        } catch (ThrottleException e) {
+            String msg = "Error occurred when creating an accesscontroller";
+            log.error(msg, e);
+            throw new SynapseException(msg, e);
+        }
+    }
 
     public boolean mediate(MessageContext synCtx) {
 
@@ -136,7 +149,7 @@
         boolean isAllowed = throttleByConcurrency(isResponse, traceOrDebugOn, 
traceOn);
 
         if (includesIPThrottling && isAllowed && !isResponse) {
-            // do the normal throttling 
+            // do the normal throttling
             isAllowed = throttleByRate(synContext, traceOrDebugOn, traceOn);
         }
 
@@ -247,8 +260,6 @@
             }
 
             try {
-                AccessController accessControler = 
AccessControllerFactory.createAccessControler(
-                    ThrottleConstants.IP_BASE);
                 boolean canAccess = accessControler.canAccess(throttleContext, 
remoteIP);
                 if (traceOrDebugOn) {
                     traceOrDebug(traceOn, "Access " + (canAccess ? "allowed" : 
"denied")



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]