[hibernate-commits] Hibernate SVN: r18119 - core/trunk/cache-infinispan/src/main/java/org/hibernate/cache/infinispan/access.

[hibernate-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2009-12-03 04:03:35 -0500 (Thu, 03 Dec 2009)
New Revision: 18119

Modified:
   core/trunk/cache-infinispan/src/main/java/org/hibernate/cache/infinispan/access/TransactionalAccessDelegate.java
Log:
[HHH-4575] (When Infinispan is configured for INVALIDATION don't send cluster message on entity insert) Fixed.

Modified: core/trunk/cache-infinispan/src/main/java/org/hibernate/cache/infinispan/access/TransactionalAccessDelegate.java
===================================================================
--- core/trunk/cache-infinispan/src/main/java/org/hibernate/cache/infinispan/access/TransactionalAccessDelegate.java	2009-12-03 09:03:31 UTC (rev 18118)
+++ core/trunk/cache-infinispan/src/main/java/org/hibernate/cache/infinispan/access/TransactionalAccessDelegate.java	2009-12-03 09:03:35 UTC (rev 18119)
@@ -32,6 +32,7 @@
 import org.hibernate.cache.infinispan.impl.BaseRegion;
 import org.hibernate.cache.infinispan.util.CacheAdapter;
 import org.hibernate.cache.infinispan.util.CacheHelper;
+import org.hibernate.cache.infinispan.util.FlagAdapter;
 import org.infinispan.util.logging.Log;
 import org.infinispan.util.logging.LogFactory;
 
@@ -109,7 +110,12 @@
    public boolean insert(Object key, Object value, Object version) throws CacheException {
       if (!region.checkValid())
          return false;
-      cacheAdapter.put(key, value);
+
+      if (cacheAdapter.isClusteredInvalidation())
+         cacheAdapter.withFlags(FlagAdapter.CACHE_MODE_LOCAL).put(key, value);
+      else
+         cacheAdapter.put(key, value);
+
       return true;
    }