JmsTemplate 未正确浏览队列

Question

我总是得到空列表。我的队列中有尚未消耗的消息。我正在传递正确的队列名称。

List<TextMessage> messages = jmsTemplate.browse(destinationQueueName, (session, browser) -> {
    Enumeration<?> browserEnumeration = browser.getEnumeration();
    List<TextMessage> messageList = new ArrayList<TextMessage>();
    while (browserEnumeration.hasMoreElements()) {
        messageList.add((TextMessage) browserEnumeration.nextElement());
    }
    
    return messageList;
});

Answer 1

我可以确认有问题的代码是正确的。我在 Kotlin 中成功使用代码来计算 Azure 服务总线的死信队列中的消息数量。

var messageCount = 0
serviceBusDeadLetterQueueJmsTemplate.browse("${destination}/\$deadletterqueue") { _, queueBrowser ->
    val browserEnumeration = queueBrowser.enumeration
    while (browserEnumeration.hasMoreElements()) {
        browserEnumeration.nextElement()
        messageCount++
    }
}
return messageCount

要找出问题所在，可以在回调中放置一个断点。