svn commit: r783521 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/CacheMediator.java

[ruwan]

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() {