org.jboss.as.clustering.infinispan.invoker

Class RetryingCacheInvoker

java.lang.Object

org.jboss.as.clustering.infinispan.invoker.RetryingCacheInvoker

All Implemented Interfaces:

CacheInvoker

public class RetryingCacheInvoker
extends Object
implements CacheInvoker

A cache invoker implementation that retries after a specified set of intervals upon timeout or suspect. If the invocation includes Flag.FAIL_SILENTLY, this will only be applied to the last attempt.

Author:

Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.as.clustering.infinispan.invoker.CacheInvoker

CacheInvoker.Operation<K,V,R>

Constructor Summary

Constructors

Constructor and Description
RetryingCacheInvoker(CacheInvoker invoker, int... backOffIntervals)
RetryingCacheInvoker(int... backOffIntervals) Creates a new RetryingCacheInvoker.

Method Summary

Modifier and Type	Method and Description
<K,V,R> R	invoke(org.infinispan.Cache<K,V> cache, CacheInvoker.Operation<K,V,R> operation, org.infinispan.context.Flag... allFlags) Invokes the specified operation on the specified cache.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetryingCacheInvoker

public RetryingCacheInvoker(int... backOffIntervals)

Creates a new RetryingCacheInvoker.

Parameters:

backOffIntervals - specifies the sleep intervals between retries, and implicitly, the number of retries

RetryingCacheInvoker

public RetryingCacheInvoker(CacheInvoker invoker,
                            int... backOffIntervals)

Method Detail

invoke

public <K,V,R> R invoke(org.infinispan.Cache<K,V> cache,
                        CacheInvoker.Operation<K,V,R> operation,
                        org.infinispan.context.Flag... allFlags)

Invokes the specified operation on the specified cache.

Specified by:

invoke in interface CacheInvoker

R - the type of the cache operation result

Parameters:

cache - an infinispan cache

operation - a cache operation

allFlags - an optional set of invocation flags

Returns:

the result of the cache operation

See Also:

org.jboss.as.clustering.infinispan.invoker.CacheInvoker#invoke(org.infinispan.Cache, org.jboss.as.clustering.infinispan.invoker.CacheInvoker.Operation)