Class StreamRetryOperationsInterceptorFactoryBean

  • All Implemented Interfaces:
    org.springframework.beans.factory.FactoryBean<org.aopalliance.aop.Advice>

    public class StreamRetryOperationsInterceptorFactoryBean
    extends org.springframework.amqp.rabbit.config.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 attempt or the backoff in between attempts, supply a customized RetryTemplate. 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.
    See Also:
    RetryOperations.execute(org.springframework.retry.RetryCallback,org.springframework.retry.RecoveryCallback)
    • 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected org.springframework.retry.interceptor.MethodInvocationRecoverer<?> createRecoverer()  
      void setMessageRecoverer​(org.springframework.amqp.rabbit.retry.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, isSingleton, recover
      • Methods inherited from class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

        getMessageRecoverer, getRetryOperations, setRetryOperations
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • StreamRetryOperationsInterceptorFactoryBean

        public StreamRetryOperationsInterceptorFactoryBean()
    • Method Detail

      • createRecoverer

        protected org.springframework.retry.interceptor.MethodInvocationRecoverer<?> createRecoverer()
        Overrides:
        createRecoverer in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
      • setStreamMessageRecoverer

        public void setStreamMessageRecoverer​(StreamMessageRecoverer messageRecoverer)
        Set a StreamMessageRecoverer to call when retries are exhausted.
        Parameters:
        messageRecoverer - the recoverer.
      • setMessageRecoverer

        public void setMessageRecoverer​(org.springframework.amqp.rabbit.retry.MessageRecoverer messageRecoverer)
        Overrides:
        setMessageRecoverer in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean