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 2009/06/10 23:14:41 UTC
svn commit: r783521 -
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java
Author: ruwan
Date: Wed Jun 10 21:14:41 2009
New Revision: 783521
URL: http://svn.apache.org/viewvc?rev=783521&view=rev
Log:
Fixing the clustered caching issue
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java?rev=783521&r1=783520&r2=783521&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java Wed Jun 10 21:14:41 2009
@@ -220,7 +220,8 @@
}
cfgCtx.setProperty(cacheManagerKey, cacheManager);
- Replicator.replicate(cfgCtx, new String[]{cacheManagerKey});
+// Replicator.replicate(cfgCtx, new String[]{cacheManagerKey});
+ Replicator.replicate(cfgCtx);
} else {
synLog.auditWarn("A response message without a valid mapping to the " +
"request hash found. Unable to store the response in cache");
@@ -336,7 +337,8 @@
synLog.traceOrDebug("Existing cached response has expired. Reset cache element");
cfgCtx.setProperty(cacheManagerKey, cacheManager);
- Replicator.replicate(cfgCtx, new String[]{cacheManagerKey});
+// Replicator.replicate(cfgCtx, new String[]{cacheManagerKey});
+ Replicator.replicate(cfgCtx);
}
} else {
@@ -375,7 +377,8 @@
cacheManager.addResponseWithKey(requestHash, cachedObj, cfgCtx);
cfgCtx.setProperty(cacheManagerKey, cacheManager);
- Replicator.replicate(cfgCtx, new String[]{cacheManagerKey});
+// Replicator.replicate(cfgCtx, new String[]{cacheManagerKey});
+ Replicator.replicate(cfgCtx);
}
public String getId() {