gpt4 book ai didi

java - JMS 消息选择器是否通过单个 Consumer.receive() 调用或它看到的第一条消息拉取多条消息?

转载 作者:行者123 更新时间:2023-12-01 20:12:40 25 4
gpt4 key购买 nike

我目前正在使用 IBM MQ JMS 库并编写一个 Java 类,该类将使用如下选择器处理从消费队列中拉取消息:

consumer = session.createConsumer(queue, "JMSCorrelationID = '" + request.getCorrelationID() + "'");
message = consumer.receive(30000);

我的问题是,如果消费队列中有两条消息与消息选择器匹配,那么调用consumer.receive会拉下这两条消息还是只会拉下它看到的第一条消息?

我发现了另一个问题: How to remove multiple messages using message selector in JMS这似乎暗示了这样一个事实:即使消费队列中的两条消息与选择器匹配,调用 receive 也会拉下一条消息。

最佳答案

MessageConsumer 的文档说明如下:

Receives the next message that arrives within the specified timeout interval.

https://docs.oracle.com/javaee/7/api/javax/jms/MessageConsumer.html

因此调用 receive 应该一次拉下 1 条消息。它不能真正返回更多消息,因为返回类型是 Message 而不是任何类型的集合。

关于java - JMS 消息选择器是否通过单个 Consumer.receive() 调用或它看到的第一条消息拉取多条消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46435439/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com