- 49
- 0
利用RetryOperationsInterceptor做重试机制,假如某个消息抛异常重试,会导致这个消息之后的来的消息一直被阻塞吗?还是这个重试的消息被插到队尾,让其他消息消费?
@Bean
SimpleRabbitListenerContainerFactory lowLoadRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory()
factory.connectionFactory = connectionFactory
factory.concurrentConsumers = 1
factory.maxConcurrentConsumers = 1
factory.recoveryInterval = 1000L
factory.setAdviceChain(retryOperationsInterceptor())
return factory
}
@Bean
RetryOperationsInterceptor retryOperationsInterceptor() {
RetryTemplate retryTemplate = new RetryTemplate()
RetryPolicy retryPolicy = new SimpleRetryPolicy(Integer.MAX_VALUE)
retryPolicy.setMaxAttempts(5)
ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy()
backOffPolicy.setInitialInterval(60000)
backOffPolicy.setMultiplier(2)
backOffPolicy.setMaxInterval(3600000)
retryTemplate.setRetryPolicy(retryPolicy)
retryTemplate.setBackOffPolicy(backOffPolicy)
retryTemplate.registerListener(new RetryListener() {
@Override
<T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
return true
}
@Override
<T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
if (throwable != null) {
log.error("Failed: Retry count " + context.getRetryCount(), throwable)
}
}
@Override
<T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
log.error("Retry count " + context.getRetryCount(), throwable)
}
})
RetryOperationsInterceptor interceptor = RetryInterceptorBuilder.stateless()
.retryOperations(retryTemplate)
.build()
return interceptor
} 0
打赏
收藏
点击回答
您的回答被采纳后将获得:提问者悬赏的 10 元积分
网站公告
- 扫一扫访问手机版
回答动态

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题函数计算不同地域的是不能用内网吧?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题在ARMS如何申请加入公测呀?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的,这个init方法在哪里进行添加?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器刚到期,是不是就不能再导出存档了呢?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容 尝试更新怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后 就链接不上了,怎么办?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了,怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了,是什么情况?预计能赚取 0积分收益
- 回到顶部
- 回到顶部
