AmqpItemReader 和死信队列
AmqpItemReader and Dead Letter Queue
我正在尝试实现一个从队列中读取消息并在发生错误时将它们移至死信的作业。我尝试使用事务处理通道，但它总是重新排队消息。
是否有任何自动方法可以在抛出异常时使用 Spring 批处理？
请参考 Spring 关于 Dead Lettering 的 AMQP。
有 RejectAndDontRequeueRecoverer，您可以为 AmqpItemReader 将其注入 RabbitTemplate。因此，所有这些 .receive() 都将包含重试建议，并且在耗尽消息的情况下将拒绝配置的 DLX。
我正在尝试实现一个从队列中读取消息并在发生错误时将它们移至死信的作业。我尝试使用事务处理通道，但它总是重新排队消息。
是否有任何自动方法可以在抛出异常时使用 Spring 批处理？
请参考 Spring 关于 Dead Lettering 的 AMQP。
有 RejectAndDontRequeueRecoverer，您可以为 AmqpItemReader 将其注入 RabbitTemplate。因此，所有这些 .receive() 都将包含重试建议，并且在耗尽消息的情况下将拒绝配置的 DLX。