org.springframework.retry.annotation

Class AnnotationAwareRetryOperationsInterceptor

java.lang.Object

org.springframework.retry.annotation.AnnotationAwareRetryOperationsInterceptor

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor, org.springframework.aop.DynamicIntroductionAdvice, org.springframework.aop.IntroductionInterceptor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware

public class AnnotationAwareRetryOperationsInterceptor
extends java.lang.Object
implements org.springframework.aop.IntroductionInterceptor, org.springframework.beans.factory.BeanFactoryAware

WrappeMethodInterceptorr interceptor that interprets the retry metadata on the method it is invoking and delegates to an appropriate RetryOperationsInterceptor.

Since:

1.1

Field Summary

Fields

Modifier and Type	Field and Description
private org.springframework.beans.factory.BeanFactory	beanFactory
private java.util.Map<java.lang.reflect.Method,org.aopalliance.intercept.MethodInterceptor>	delegates
private MethodArgumentsKeyGenerator	methodArgumentsKeyGenerator
private NewMethodArgumentsIdentifier	newMethodArgumentsIdentifier
private RetryContextCache	retryContextCache
private Sleeper	sleeper

Constructor Summary

Constructors

Constructor and Description
AnnotationAwareRetryOperationsInterceptor()

Method Summary

Modifier and Type	Method and Description
private BackOffPolicy	getBackoffPolicy(Backoff backoff)
private org.aopalliance.intercept.MethodInterceptor	getDelegate(java.lang.Object target, java.lang.reflect.Method method)
private MethodInvocationRecoverer<?>	getRecoverer(java.lang.Object target, java.lang.reflect.Method method)
private RetryPolicy	getRetryPolicy(Retryable retryable)
private org.aopalliance.intercept.MethodInterceptor	getStatefulInterceptor(java.lang.Object target, java.lang.reflect.Method method, Retryable retryable)
private org.aopalliance.intercept.MethodInterceptor	getStatelessInterceptor(java.lang.Object target, java.lang.reflect.Method method, Retryable retryable)
boolean	implementsInterface(java.lang.Class<?> intf)
java.lang.Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setKeyGenerator(MethodArgumentsKeyGenerator methodArgumentsKeyGenerator)
void	setNewItemIdentifier(NewMethodArgumentsIdentifier newMethodArgumentsIdentifier)
void	setRetryContextCache(RetryContextCache retryContextCache) Public setter for the RetryContextCache.
void	setSleeper(Sleeper sleeper)

Methods inherited from class java.lang.Object

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

Field Detail

delegates

private final java.util.Map<java.lang.reflect.Method,org.aopalliance.intercept.MethodInterceptor> delegates

retryContextCache

private RetryContextCache retryContextCache

methodArgumentsKeyGenerator

private MethodArgumentsKeyGenerator methodArgumentsKeyGenerator

newMethodArgumentsIdentifier

private NewMethodArgumentsIdentifier newMethodArgumentsIdentifier

sleeper

private Sleeper sleeper

beanFactory

private org.springframework.beans.factory.BeanFactory beanFactory

Constructor Detail

AnnotationAwareRetryOperationsInterceptor

public AnnotationAwareRetryOperationsInterceptor()

Method Detail

setSleeper

public void setSleeper(Sleeper sleeper)

Parameters:

sleeper - the sleeper to set

setRetryContextCache

public void setRetryContextCache(RetryContextCache retryContextCache)

Public setter for the RetryContextCache.

Parameters:

retryContextCache - the RetryContextCache to set.

setKeyGenerator

public void setKeyGenerator(MethodArgumentsKeyGenerator methodArgumentsKeyGenerator)

Parameters:

methodArgumentsKeyGenerator - the MethodArgumentsKeyGenerator

setNewItemIdentifier

public void setNewItemIdentifier(NewMethodArgumentsIdentifier newMethodArgumentsIdentifier)

Parameters:

newMethodArgumentsIdentifier - the NewMethodArgumentsIdentifier

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

implementsInterface

public boolean implementsInterface(java.lang.Class<?> intf)

Specified by:

implementsInterface in interface org.springframework.aop.DynamicIntroductionAdvice

invoke

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

Specified by:

invoke in interface org.aopalliance.intercept.MethodInterceptor

Throws:

java.lang.Throwable

getDelegate

private org.aopalliance.intercept.MethodInterceptor getDelegate(java.lang.Object target,
                                                                java.lang.reflect.Method method)

getStatelessInterceptor

private org.aopalliance.intercept.MethodInterceptor getStatelessInterceptor(java.lang.Object target,
                                                                            java.lang.reflect.Method method,
                                                                            Retryable retryable)

getStatefulInterceptor

private org.aopalliance.intercept.MethodInterceptor getStatefulInterceptor(java.lang.Object target,
                                                                           java.lang.reflect.Method method,
                                                                           Retryable retryable)

getRecoverer

private MethodInvocationRecoverer<?> getRecoverer(java.lang.Object target,
                                                  java.lang.reflect.Method method)

getRetryPolicy

private RetryPolicy getRetryPolicy(Retryable retryable)

getBackoffPolicy

private BackOffPolicy getBackoffPolicy(Backoff backoff)