org.springframework.integration.handler.advice

Class RequestHandlerRetryAdvice

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

org.springframework.integration.handler.advice.RequestHandlerRetryAdvice

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, ExpressionCapable, NamedComponent, org.springframework.retry.RetryListener

public class RequestHandlerRetryAdvice
extends AbstractRequestHandlerAdvice
implements org.springframework.retry.RetryListener

Uses spring-retry to perform stateless or stateful retry. Stateless retry means the retries are performed internally by the RetryTemplate; stateful retry means the exception is thrown but state is maintained to support the retry policies. Stateful retry requires a RetryStateGenerator.

Since:

2.2

Author:

Gary Russell, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

AbstractRequestHandlerAdvice.ExecutionCallback

Field Summary

Fields inherited from class org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

logger

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER

Constructor Summary

Constructors

Constructor and Description
RequestHandlerRetryAdvice()

Method Summary

Modifier and Type	Method and Description
<T,E extends java.lang.Throwable> void	close(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback, java.lang.Throwable throwable)
protected java.lang.Object	doInvoke(AbstractRequestHandlerAdvice.ExecutionCallback callback, java.lang.Object target, org.springframework.messaging.Message<?> message) Subclasses implement this method to apply behavior to the MessageHandler.
<T,E extends java.lang.Throwable> void	onError(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback, java.lang.Throwable throwable)
protected void	onInit() Subclasses may implement this for initialization logic.
<T,E extends java.lang.Throwable> boolean	open(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback)
void	setRecoveryCallback(org.springframework.retry.RecoveryCallback<java.lang.Object> recoveryCallback)
void	setRetryStateGenerator(RetryStateGenerator retryStateGenerator)
void	setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

Methods inherited from class org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice

invoke, unwrapExceptionIfNecessary, unwrapThrowableIfNecessary

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestHandlerRetryAdvice

public RequestHandlerRetryAdvice()

Method Detail

setRetryTemplate

public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

setRecoveryCallback

public void setRecoveryCallback(org.springframework.retry.RecoveryCallback<java.lang.Object> recoveryCallback)

setRetryStateGenerator

public void setRetryStateGenerator(RetryStateGenerator retryStateGenerator)

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

java.lang.Exception - Any exception.

doInvoke

protected java.lang.Object doInvoke(AbstractRequestHandlerAdvice.ExecutionCallback callback,
                                    java.lang.Object target,
                                    org.springframework.messaging.Message<?> message)
                             throws java.lang.Exception

Description copied from class: AbstractRequestHandlerAdvice

Subclasses implement this method to apply behavior to the MessageHandler.

callback.execute() invokes the handler method and returns its result, or null.

Specified by:

doInvoke in class AbstractRequestHandlerAdvice

Parameters:

callback - Subclasses invoke the execute() method on this interface to invoke the handler method.

target - The target handler.

message - The message that will be sent to the handler.

Returns:

the result after invoking the MessageHandler.

Throws:

java.lang.Exception - Any Exception.

open

public <T,E extends java.lang.Throwable> boolean open(org.springframework.retry.RetryContext context,
                                                      org.springframework.retry.RetryCallback<T,E> callback)

Specified by:

open in interface org.springframework.retry.RetryListener

close

public <T,E extends java.lang.Throwable> void close(org.springframework.retry.RetryContext context,
                                                    org.springframework.retry.RetryCallback<T,E> callback,
                                                    java.lang.Throwable throwable)

Specified by:

close in interface org.springframework.retry.RetryListener

onError

public <T,E extends java.lang.Throwable> void onError(org.springframework.retry.RetryContext context,
                                                      org.springframework.retry.RetryCallback<T,E> callback,
                                                      java.lang.Throwable throwable)

Specified by:

onError in interface org.springframework.retry.RetryListener