Class StreamRetryOperationsInterceptorFactoryBean

java.lang.Object
org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
org.springframework.rabbit.stream.retry.StreamRetryOperationsInterceptorFactoryBean
All Implemented Interfaces:
FactoryBean<Advice>
public class StreamRetryOperationsInterceptorFactoryBean extends StatelessRetryOperationsInterceptorFactoryBean
Convenient factory bean for creating a stateless retry interceptor for use in a StreamListenerContainer when consuming native stream messages, giving you a large amount of control over the behavior of a container when a listener fails. To control the number of retry attempts or the backoff in between attempts, supply a customized RetryOperations. Stateless retry is appropriate if your listener can be called repeatedly between failures with no side effects. The semantics of stateless retry mean that a listener exception is not propagated to the container until the retry attempts are exhausted. When the retry attempts are exhausted it can be processed using a StreamMessageRecoverer if one is provided.
Author:
Gary Russell, Stephane Nicoll