如何使用 Spring AMQP 读取队列中的消息?
How to use Spring AMQP to read messages in a queue?
给定一个包含消息的队列,我如何使用 Spring AMQP 获取存储在该队列中的所有消息?注意,问题不询问如何收听队列。
抱歉,我认为这样的解决方案没有任何意义。 监听所有消息的队列确实更好。如果您需要 browse 之类的东西 - 获取并重新排队(或 nack
),那么 AmqpTemplate.receive()
是不错的选择。您应该将该调用包装到 TX(例如仅使用 RabbitTransactionManager
),执行 while(true)
直到 receive()
returns 消息和最后的 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()
。
给定一个包含消息的队列,我如何使用 Spring AMQP 获取存储在该队列中的所有消息?注意,问题不询问如何收听队列。
抱歉,我认为这样的解决方案没有任何意义。 监听所有消息的队列确实更好。如果您需要 browse 之类的东西 - 获取并重新排队(或 nack
),那么 AmqpTemplate.receive()
是不错的选择。您应该将该调用包装到 TX(例如仅使用 RabbitTransactionManager
),执行 while(true)
直到 receive()
returns 消息和最后的 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()
。