Package org.springframework.amqp.rabbit.retry

Examples of org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer


      RetryOperationsInterceptor retryInterceptor = RetryInterceptorBuilder.stateless()
          .maxAttempts(maxAttempts)
          .backOffOptions(properties.getBackOffInitialInterval(this.defaultBackOffInitialInterval),
              properties.getBackOffMultiplier(this.defaultBackOffMultiplier),
              properties.getBackOffMaxInterval(this.defaultBackOffMaxInterval))
          .recoverer(new RejectAndDontRequeueRecoverer())
          .build();
      listenerContainer.setAdviceChain(new Advice[] { retryInterceptor });
    }
    listenerContainer.afterPropertiesSet();
    AmqpInboundChannelAdapter adapter = new AmqpInboundChannelAdapter(listenerContainer);
View Full Code Here

TOP

Related Classes of org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.