public class AnnotationAwareRetryOperationsInterceptor
extends java.lang.Object
implements org.springframework.aop.IntroductionInterceptor, org.springframework.beans.factory.BeanFactoryAware
| 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 and Description |
|---|
AnnotationAwareRetryOperationsInterceptor() |
| 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) |
private final java.util.Map<java.lang.reflect.Method,org.aopalliance.intercept.MethodInterceptor> delegates
private RetryContextCache retryContextCache
private MethodArgumentsKeyGenerator methodArgumentsKeyGenerator
private NewMethodArgumentsIdentifier newMethodArgumentsIdentifier
private Sleeper sleeper
private org.springframework.beans.factory.BeanFactory beanFactory
public AnnotationAwareRetryOperationsInterceptor()
public void setSleeper(Sleeper sleeper)
sleeper - the sleeper to setpublic void setRetryContextCache(RetryContextCache retryContextCache)
RetryContextCache.retryContextCache - the RetryContextCache to set.public void setKeyGenerator(MethodArgumentsKeyGenerator methodArgumentsKeyGenerator)
methodArgumentsKeyGenerator - the MethodArgumentsKeyGeneratorpublic void setNewItemIdentifier(NewMethodArgumentsIdentifier newMethodArgumentsIdentifier)
newMethodArgumentsIdentifier - the NewMethodArgumentsIdentifierpublic void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
throws org.springframework.beans.BeansException
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwareorg.springframework.beans.BeansExceptionpublic boolean implementsInterface(java.lang.Class<?> intf)
implementsInterface in interface org.springframework.aop.DynamicIntroductionAdvicepublic java.lang.Object invoke(org.aopalliance.intercept.MethodInvocation invocation)
throws java.lang.Throwable
invoke in interface org.aopalliance.intercept.MethodInterceptorjava.lang.Throwableprivate org.aopalliance.intercept.MethodInterceptor getDelegate(java.lang.Object target,
java.lang.reflect.Method method)
private org.aopalliance.intercept.MethodInterceptor getStatelessInterceptor(java.lang.Object target,
java.lang.reflect.Method method,
Retryable retryable)
private org.aopalliance.intercept.MethodInterceptor getStatefulInterceptor(java.lang.Object target,
java.lang.reflect.Method method,
Retryable retryable)
private MethodInvocationRecoverer<?> getRecoverer(java.lang.Object target, java.lang.reflect.Method method)
private RetryPolicy getRetryPolicy(Retryable retryable)
private BackOffPolicy getBackoffPolicy(Backoff backoff)