java - 如何在死字中使用 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；您可以在恢复器中完全控制消息的去向。