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, NamedComponent

public class RequestHandlerRetryAdvice
extends AbstractRequestHandlerAdvice

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

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

Constructor Summary

RequestHandlerRetryAdvice()

Method Summary

protected java.lang.Object	doInvoke(AbstractRequestHandlerAdvice.ExecutionCallback callback, java.lang.Object target, Message<?> message) Subclasses implement this method to apply behavior to the MessageHandler. callback.execute() invokes the handler method and returns its result, or null.
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

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

afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setComponentName, setConversionService, 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)

doInvoke

protected java.lang.Object doInvoke(AbstractRequestHandlerAdvice.ExecutionCallback callback,
                                    java.lang.Object target,
                                    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