rabbitmq - 调用 RecoveryCallback 的任何方式在 RabbitTemplate 发送操作中？

Question

我目前正在使用 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 提供了更清晰的实现，我不想走这条路。

score 0 · Accepted Answer

你是对的：现在没有这样的能力。

请随意提出JIRA 问题，我们会尽快解决。

谢谢。

而且我认为您采用一种解决方法是正确的：您实际上只是在内联实现中使用您自己的RetryTemplate实例和原始RabbitTemplate.convertAndSend调用。doWithRetry

1 回答 1