AmqpItemReader与死信队列

Question

我正在尝试实现一个作业，该作业从队列中读取消息，并在发生错误时将它们移动到死信。我尝试使用一个事务处理的通道，但它总是要求消息。

当抛出异常时，是否有任何自动的方法来处理Spring批处理？

Answer 1

请参阅Spring关于死字的内容。

有RejectAndDontRequeueRecoverer，您可以将它插入到AmqpItemReader的RabbitTemplate中。因此，所有这些.receive()都将与重试通知一起包装，在耗尽消息的情况下，消息将被拒绝到配置的DLX。