java - 如何在Dead lettering中使用RepublishMessageRecoverer？

Question

我为我正在使用的几个队列设置了死信。在我使用的配置中:

<bean id="retryAdvice"
    class="org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean">
    <property name="messageRecoverer" ref="rejectAndDontRequeueRecoverer"/>
    <property name="retryOperations" ref="retryTemplate" />
</bean>

<bean id="rejectAndDontRequeueRecoverer" class="org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer"/>

如果我希望死信队列上的消息具有 x-exception-stacktrace ，我读到我需要使用 RepublishMessageRecoverer。在死信中使用它是否像在上述设置中用 RepublishMessageRecoverer 替换 RejectAndDontRequeueRecoverer 一样简单，还是我需要编写自定义 messageRecoverer？

Answer 1

是的，只需更换恢复器即可。根本不使用普通的 RabbitMQ 死信(消息将被确认)，并且您不需要配置 DLE/DLQ；您可以在恢复程序中完全控制消息的去向。