org.springframework.batch.retry.interceptor
Class StatefulRetryOperationsInterceptor

java.lang.Object
  org.springframework.batch.retry.interceptor.StatefulRetryOperationsInterceptor

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor

public class StatefulRetryOperationsInterceptor
extends Object
implements org.aopalliance.intercept.MethodInterceptor

A MethodInterceptor that can be used to automatically retry calls to a method on a service if it fails. The argument to the service method is treated as an item to be remembered in case the call fails. So the retry operation is stateful, and the item that failed is tracked by its unique key (via MethodArgumentsKeyGenerator) until the retry is exhausted, at which point the MethodInvocationRecoverer is called.
The main use case for this is where the service is transactional, via a transaction interceptor on the interceptor chain. In this case the retry (and recovery on exhausted) always happens in a new transaction.
The injected RetryOperations is used to control the number of retries. By default it will retry a fixed number of times, according to the defaults in RetryTemplate.

Author:

Dave Syer

Constructor Summary

StatefulRetryOperationsInterceptor()

Method Summary

Object	invoke(org.aopalliance.intercept.MethodInvocation invocation) Wrap the method invocation in a stateful retry with the policy and other helpers provided.
void	setKeyGenerator(MethodArgumentsKeyGenerator keyGenerator)
void	setNewItemIdentifier(NewMethodArgumentsIdentifier newMethodArgumentsIdentifier) Public setter for the NewMethodArgumentsIdentifier.
void	setRecoverer(MethodInvocationRecoverer<? extends Object> recoverer) Public setter for the MethodInvocationRecoverer to use if the retry is exhausted.
void	setRetryOperations(RetryOperations retryTemplate)

Methods inherited from class java.lang.Object

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

Constructor Detail

StatefulRetryOperationsInterceptor

public StatefulRetryOperationsInterceptor()

Method Detail

setRetryOperations

public void setRetryOperations(RetryOperations retryTemplate)

setRecoverer

public void setRecoverer(MethodInvocationRecoverer<? extends Object> recoverer)

Public setter for the MethodInvocationRecoverer to use if the retry is exhausted. The recoverer should be able to return an object of the same type as the target object because its return value will be used to return to the caller in the case of a recovery.
If no recoverer is set then an exhausted retry will result in an ExhaustedRetryException.

Parameters:

recoverer - the MethodInvocationRecoverer to set

setKeyGenerator

public void setKeyGenerator(MethodArgumentsKeyGenerator keyGenerator)

setNewItemIdentifier

public void setNewItemIdentifier(NewMethodArgumentsIdentifier newMethodArgumentsIdentifier)

Public setter for the NewMethodArgumentsIdentifier. Only set this if the arguments to the intercepted method can be inspected to find out if they have never been processed before.

Parameters:

newMethodArgumentsIdentifier - the NewMethodArgumentsIdentifier to set

invoke

public Object invoke(org.aopalliance.intercept.MethodInvocation invocation)
              throws Throwable

Wrap the method invocation in a stateful retry with the policy and other helpers provided. If there is a failure the exception will generally be re-thrown. The only time it is not re-thrown is when retry is exhausted and the recovery path is taken (though the MethodInvocationRecoverer provided if there is one). In that case the value returned from the method invocation will be the value returned by the recoverer (so the return type for that should be the same as the intercepted method).

Specified by:

invoke in interface org.aopalliance.intercept.MethodInterceptor

Throws:

ExhaustedRetryException - if the retry is exhausted and no MethodInvocationRecoverer is provided.

Throwable

See Also:

MethodInterceptor.invoke(org.aopalliance.intercept.MethodInvocation), MethodInvocationRecoverer.recover(Object[], Throwable)