synapse-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ind...@apache.org
Subject svn commit: r556522 [2/2] - in /webservices/synapse/trunk/java/modules: core/src/main/java/org/apache/synapse/config/xml/ core/src/main/java/org/apache/synapse/core/axis2/ core/src/main/java/org/apache/synapse/mediators/ core/src/main/java/org/apache/s...
Date Mon, 16 Jul 2007 06:43:53 GMT
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?view=diff&rev=556522&r1=556521&r2=556522
==============================================================================
--- 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
Sun Jul 15 23:43:50 2007
@@ -84,10 +84,12 @@
      */
     protected boolean canAccess(MessageContext synContext, boolean shouldTrace) {
         if (throttle == null) {
-            log.debug("Can not find a throttle");
+            if (log.isDebugEnabled()) {
+                log.debug("Can not find a throttle");
+            }
             return true;
         }
-        boolean canAccess = true;               
+        boolean canAccess = true;
         org.apache.axis2.context.MessageContext axis2MessageContext
                 = ((Axis2MessageContext) synContext).getAxis2MessageContext();
         //IP based throttling
@@ -98,8 +100,10 @@
                 trace.trace("The IP Address of the caller is cannnot find- The Throttling
will" +
                         "not occur");
             }
-            log.debug("The IP address of the caller can not find - Currently only support
caller-IP base"
-                    + "access control - Thottling will not happen ");
+            if (log.isDebugEnabled()) {
+                log.debug("The IP address of the caller can not find - Currently only support
caller-IP base"
+                        + "access control - Thottling will not happen ");
+            }
             return true;
         } else {
             if (shouldTrace) {
@@ -108,7 +112,9 @@
             ThrottleContext throttleContext
                     = throttle.getThrottleContext(ThrottleConstants.IP_BASED_THROTTLE_KEY);
             if (throttleContext == null) {
-                log.debug("Can not find a configuartion for the IP Based Throttle");
+                if (log.isDebugEnabled()) {
+                    log.debug("Can not find a configuartion for the IP Based Throttle");
+                }
                 return true;
             }
             try {
@@ -121,7 +127,9 @@
                     if (shouldTrace) {
                         trace.trace(msg);
                     }
-                    log.debug(msg);
+                    if (log.isDebugEnabled()) {
+                        log.debug(msg);
+                    }
                 }
             }
             catch (ThrottleException e) {
@@ -174,17 +182,23 @@
         if (policyKey != null) {
             Entry entry = synContext.getConfiguration().getEntryDefinition(policyKey);
             if (entry == null) {
-                log.debug("Cant not find a Entry from the Entry key " + policyKey);
+                if (log.isDebugEnabled()) {
+                    log.debug("Cant not find a Entry from the Entry key " + policyKey);
+                }
                 return;
             }
             Object entryValue = entry.getValue();
             if (entryValue == null) {
-                log.debug("Cant not find a Policy(Enrty value) from the Entry key " + policyKey);
+                if (log.isDebugEnabled()) {
+                    log.debug("Cant not find a Policy(Enrty value) from the Entry key " +
policyKey);
+                }
                 return;
             }
             if (!(entryValue instanceof OMElement)) {
-                log.debug("Entry value which is refered from the key " + policyKey + " is
Incompatible " +
-                        "for the policy element");
+                if (log.isDebugEnabled()) {
+                    log.debug("Entry value which is refered from the key " + policyKey +
" is Incompatible " +
+                            "for the policy element");
+                }
                 return;
             }
             // if entry is dynamic, need to check wheather updated or not
@@ -196,7 +210,9 @@
             policyOmElement = inLinePolicy;
         }
         if (policyOmElement == null) {
-            log.debug("Cant not find a Policy - Throttling will not occur");
+            if (log.isDebugEnabled()) {
+                log.debug("Cant not find a Policy - Throttling will not occur");
+            }
             return;
         }
         if (shouldTrace) {
@@ -220,7 +236,9 @@
      */
     protected void createThrottleMetaData(OMElement policyOmElement) {
         try {
-            log.debug("Creating a new throttle configuration by parsing the Policy");
+            if (log.isDebugEnabled()) {
+                log.debug("Creating a new throttle configuration by parsing the Policy");
+            }
             throttle = ThrottlePolicyProcessor
                     .processPoclicy(PolicyEngine.getPolicy(policyOmElement));
         }
@@ -234,8 +252,7 @@
         throw new SynapseException(msg);
     }
 
-    private void handleException(String msg, Exception e) {
-        log.debug(msg);
+    private void handleException(String msg, Exception e) {         
         log.error(e);
         throw new SynapseException(msg);
     }



---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org


Mime
View raw message