Class NonTxInvalidationCacheAccessDelegate
- java.lang.Object
-
- org.infinispan.hibernate.cache.commons.access.InvalidationCacheAccessDelegate
-
- org.infinispan.hibernate.cache.commons.access.NonTxInvalidationCacheAccessDelegate
-
- All Implemented Interfaces:
AccessDelegate
public class NonTxInvalidationCacheAccessDelegate extends InvalidationCacheAccessDelegate
Delegate for non-transactional caches- Author:
- Radim Vansa <rvansa@redhat.com>
-
-
Field Summary
Fields Modifier and Type Field Description protected org.infinispan.interceptors.AsyncInterceptorChain
invoker
protected boolean
isLocal
protected NonTxPutFromLoadInterceptor
nonTxPutFromLoadInterceptor
-
Fields inherited from class org.infinispan.hibernate.cache.commons.access.InvalidationCacheAccessDelegate
cache, log, putValidator, region, trace, writeCache
-
-
Constructor Summary
Constructors Constructor Description NonTxInvalidationCacheAccessDelegate(InfinispanDataRegion region, PutFromLoadValidator validator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
afterInsert(Object session, Object key, Object value, Object version)
Called after an item has been inserted (after the transaction completes), instead of calling release().boolean
afterUpdate(Object session, Object key, Object value, Object currentVersion, Object previousVersion, org.hibernate.cache.spi.access.SoftLock lock)
Called after an item has been updated (after the transaction completes), instead of calling release().boolean
insert(Object session, Object key, Object value, Object version)
Called after an item has been inserted (before the transaction completes), instead of calling evict().protected void
invoke(Object session, org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
protected void
registerClusteredInvalidation(Object session, Object lockOwner, Object key)
protected void
registerLocalInvalidation(Object session, Object lockOwner, Object key)
void
remove(Object session, Object key)
Called after an item has become stale (before the transaction completes).void
removeAll()
Called to evict data from the entire regionboolean
update(Object session, Object key, Object value, Object currentVersion, Object previousVersion)
Called after an item has been updated (before the transaction completes), instead of calling evict().-
Methods inherited from class org.infinispan.hibernate.cache.commons.access.InvalidationCacheAccessDelegate
evict, evictAll, get, putFromLoad, putFromLoad, unlockItem
-
-
-
-
Field Detail
-
invoker
protected final org.infinispan.interceptors.AsyncInterceptorChain invoker
-
nonTxPutFromLoadInterceptor
protected final NonTxPutFromLoadInterceptor nonTxPutFromLoadInterceptor
-
isLocal
protected final boolean isLocal
-
-
Constructor Detail
-
NonTxInvalidationCacheAccessDelegate
public NonTxInvalidationCacheAccessDelegate(InfinispanDataRegion region, PutFromLoadValidator validator)
-
-
Method Detail
-
insert
public boolean insert(Object session, Object key, Object value, Object version) throws org.hibernate.cache.CacheException
Description copied from interface:AccessDelegate
Called after an item has been inserted (before the transaction completes), instead of calling evict().- Parameters:
session
- Current sessionkey
- The item keyvalue
- The itemversion
- The item's version value- Returns:
- Were the contents of the cache actual changed by this operation?
- Throws:
org.hibernate.cache.CacheException
- if the insert fails
-
update
public boolean update(Object session, Object key, Object value, Object currentVersion, Object previousVersion) throws org.hibernate.cache.CacheException
Description copied from interface:AccessDelegate
Called after an item has been updated (before the transaction completes), instead of calling evict().- Parameters:
session
- Current sessionkey
- The item keyvalue
- The itemcurrentVersion
- The item's current version valuepreviousVersion
- The item's previous version value- Returns:
- Whether the contents of the cache actual changed by this operation
- Throws:
org.hibernate.cache.CacheException
- if the update fails
-
remove
public void remove(Object session, Object key) throws org.hibernate.cache.CacheException
Description copied from interface:AccessDelegate
Called after an item has become stale (before the transaction completes).- Specified by:
remove
in interfaceAccessDelegate
- Overrides:
remove
in classInvalidationCacheAccessDelegate
- Parameters:
session
- Current sessionkey
- The key of the item to remove- Throws:
org.hibernate.cache.CacheException
- if removing the cached item fails
-
invoke
protected void invoke(Object session, org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
-
afterInsert
public boolean afterInsert(Object session, Object key, Object value, Object version)
Description copied from interface:AccessDelegate
Called after an item has been inserted (after the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.key
- The item keyvalue
- The itemversion
- The item's version value- Returns:
- Were the contents of the cache actual changed by this operation?
-
afterUpdate
public boolean afterUpdate(Object session, Object key, Object value, Object currentVersion, Object previousVersion, org.hibernate.cache.spi.access.SoftLock lock)
Description copied from interface:AccessDelegate
Called after an item has been updated (after the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.key
- The item keyvalue
- The itemcurrentVersion
- The item's current version valuepreviousVersion
- The item's previous version valuelock
- The lock previously obtained from#lockItem
- Returns:
- Were the contents of the cache actual changed by this operation?
-
removeAll
public void removeAll() throws org.hibernate.cache.CacheException
Description copied from interface:AccessDelegate
Called to evict data from the entire region- Specified by:
removeAll
in interfaceAccessDelegate
- Overrides:
removeAll
in classInvalidationCacheAccessDelegate
- Throws:
org.hibernate.cache.CacheException
- if eviction the region fails
-
registerLocalInvalidation
protected void registerLocalInvalidation(Object session, Object lockOwner, Object key)
-
-