我有以下两种情况
- 的情况下例外AL:重试有限次数
最后当重试次数用尽时,消息被写入
死信队列
- 的情况下异常B:简单来说,消息应该写到
死信队列
我想在同一个侦听器容器工厂和同一个队列上支持这两种情况。
我已经有以下配置来支持case 1成功地:
@Bean
public RetryOperationsInterceptor workMessagesRetryInterceptor() {
return RetryInterceptorBuilder.stateless()
.maxAttempts(5)
.backOffOptions(1000, 2, 10000)
.recoverer(new RejectAndDontRequeueRecoverer())
.build();
}
@Bean
public SimpleRabbitListenerContainerFactory myRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setMaxConcurrentConsumers(8);
factory.setAdviceChain(workMessagesRetryInterceptor());
return factory;
}`
现在我想扩展之前的配置来支持情况 2。
编辑,感谢加里的快速回复。
这是我的新配置,但我仍然获得重审关于两个异常: ListenerExecutionFailedException 、 AmqpRejectAndDontRequeueException
@Bean
public SimpleRetryPolicy rejectionRetryPolicy(){
Map<Class<? extends Throwable> , Boolean> exceptionsMap = new HashMap<Class<? extends Throwable> , Boolean>();
exceptionsMap.put(ListenerExecutionFailedException.class, true); //retriable
exceptionsMap.put(AmqpRejectAndDontRequeueException.class, false);//not retriable
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(5 , exceptionsMap );
return retryPolicy;
}
@Bean
public RetryOperationsInterceptor workMessagesRetryInterceptor() {
return RetryInterceptorBuilder.stateless().retryPolicy(rejectionRetryPolicy())
//.backOffOptions(1000, 2, 10000)
//.recoverer(new RejectAndDontRequeueRecoverer())
.build();
}
提供一个SimpleRetryPolicy
带有异常和布尔值的映射(是否重试)。您可以选择遍历异常原因树来查找特定的异常。请参阅SimpleRetryPolicy 的 Javadoc https://github.com/spring-projects/spring-retry/blob/master/src/main/java/org/springframework/retry/policy/SimpleRetryPolicy.java#L73.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)