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.

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(int... backOffIntervals) Creates a new RetryingCacheInvoker.

Method Summary

Methods

Modifier and Type	Method and Description
<K,V,R> R	invoke(org.infinispan.Cache<K,V> cache, CacheInvoker.Operation<K,V,R> operation) 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

Method Detail

invoke

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

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

Returns:

the result of the cache operation

See Also:

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