假设我们只有一个消费者,我们的重新发送政策将允许该消息在很长一段时间内重新传递.
我尝试了一种情况,我发送了两条消息(不同的类型),一个被设计为重新传送,另一个可以正常消费.
如果它比重新传递的消息晚发送,似乎正常消息将被阻止.在重新传递的消息多次尝试达到最大重传时间之前,它不会被消耗.这将导致易于消费的消息必须等待很长时间才能消耗的情况.
我想知道AMQ重新启动是如何工作的.当在消费者中重新传递消息时,可以将另一消息发送给该消费者,直到当前消息被消耗或超时(到DLQ).
有人可以帮忙吗？谢谢,