我在任何地方都找不到此信息。我有两个队列,@JmsListener(destination = "p1")
,@JmsListener(destination = "p2")
。如何确保即使我正在侦听2个队列,一次也只能处理1条消息,以及如何配置对首先收到消息的队列的轮询,也就是在处理了要轮询的消息之后p1
首先。或进行加权轮询:p1
:90%,p2
:10%。等
基本上,我在问如何为Spring
实施消息的优先级处理。我正在使用不支持优先级的SQS
。
使用JmsTemplate
receive()
或receiveAndConvert()
方法之一,而不是消息驱动模型。
如果要确保没有消息丢失,请使用事务。