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

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean

logger

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
StreamRetryOperationsInterceptorFactoryBean()

Method Summary

Modifier and Type	Method	Description
protected @Nullable Object	recover(@Nullable Object[] args, Throwable cause)
void	setMessageRecoverer(MessageRecoverer messageRecoverer)
void	setStreamMessageRecoverer(StreamMessageRecoverer messageRecoverer)	Set a StreamMessageRecoverer to call when retries are exhausted.

Methods inherited from class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean

getObject, getObjectType

Methods inherited from class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

getMessageRecoverer, getRetryPolicy, setRetryPolicy

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Constructor Details

StreamRetryOperationsInterceptorFactoryBean

public StreamRetryOperationsInterceptorFactoryBean()

Method Details

recover

protected @Nullable Object recover(@Nullable Object[] args,
 Throwable cause)

Overrides:

recover in class StatelessRetryOperationsInterceptorFactoryBean

setStreamMessageRecoverer

public void setStreamMessageRecoverer(StreamMessageRecoverer messageRecoverer)

Set a StreamMessageRecoverer to call when retries are exhausted.

Parameters:

messageRecoverer - the recoverer.

setMessageRecoverer

public void setMessageRecoverer(MessageRecoverer messageRecoverer)

Overrides:

setMessageRecoverer in class AbstractRetryOperationsInterceptorFactoryBean