You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by ru...@apache.org on 2007/09/25 05:08:17 UTC

svn commit: r579042 - in /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: config/Entry.java registry/AbstractRegistry.java

Author: ruwan
Date: Mon Sep 24 20:08:15 2007
New Revision: 579042

URL: http://svn.apache.org/viewvc?rev=579042&view=rev
Log:
Changing the default registry entry cacheabale duration to never expire, rather then always expire

Modified:
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/AbstractRegistry.java

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java?rev=579042&r1=579041&r2=579042&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java Mon Sep 24 20:08:15 2007
@@ -145,7 +145,7 @@
     }
 
     public boolean isExpired() {
-        if(getType() == REMOTE_ENTRY) {
+        if (getType() == REMOTE_ENTRY && getExpiryTime() > 0) {
             return System.currentTimeMillis() > expiryTime;
         } else {
             return false;

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/AbstractRegistry.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/AbstractRegistry.java?rev=579042&r1=579041&r2=579042&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/AbstractRegistry.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/AbstractRegistry.java Mon Sep 24 20:08:15 2007
@@ -83,8 +83,12 @@
 
                 // renew cache lease for another cachable duration (as returned by the
                 // new getRegistryEntry() call
-                entry.setExpiryTime(
-                    System.currentTimeMillis() + re.getCachableDuration());
+                if (re.getCachableDuration() > 0) {
+                    entry.setExpiryTime(
+                            System.currentTimeMillis() + re.getCachableDuration());
+                } else {
+                    entry.setExpiryTime(-1);
+                }
                 if (log.isDebugEnabled()) {
                     log.debug("Renew cache lease for another " + re.getCachableDuration() / 1000 + "s");
                 }
@@ -132,7 +136,11 @@
 
         // increment cache expiry time as specified by the last getRegistryEntry() call
         if (re != null) {
-            entry.setExpiryTime(System.currentTimeMillis() + re.getCachableDuration());
+            if (re.getCachableDuration() > 0) {
+                entry.setExpiryTime(System.currentTimeMillis() + re.getCachableDuration());
+            } else {
+                entry.setExpiryTime(-1);
+            }
             entry.setVersion(re.getVersion());
         }
 



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