我目前正在使用 Spring AMQP 版本1.3.6.RELEASE
和 Spring Retry 1.1.2.RELEASE
。根据 Spring AMQP 文档第3.3.1节,可以通过传入RetryTemplate
.
是否有任何现有的能力来提供RecoveryCallback<T>
实现?我正在查看RabbitTemplate.java实现,但找不到任何内容。
我正在考虑的用例是,如果*Send()
由于代理关闭而导致执行失败,我想实现自己的自定义逻辑。
我知道我可以将convertAndSend()
调用包装在自己的RetryTemplate
实现中并实现 atry { ... } catch (AmqpException e) { ... }
但如果 Spring AMQP 提供了更清晰的实现,我不想走这条路。