How to make Queue browser to stop listening when no more message are in queue?

pruffieux

Context: I am using the Java API for browsing messages.

I have my code looking like this:

MessagingService messagingService = createMessagingService(clientUser, clientPass);

Queue queue = Queue.durableExclusiveQueue(queueToBrowse);

MessageQueueBrowser browser;


if (selector == null || selector.isEmpty()) {

	browser = messagingService.createMessageQueueBrowserBuilder()

					  .build(queue)

					  .start();

} else {

	browser = messagingService.createMessageQueueBrowserBuilder()

					  .withMessageSelector(selector)

					  .build(queue)

					  .start();

}


if (limit == 0 || limit > 500) {

	limit = 500;

}


for (int msgCount = 0; msgCount < limit; msgCount++) {

	InboundMessage message = browser.receiveMessage();

	LOGGER.info("Found a message");

	result.add(queueResultMapper.toMessageDto(message));

}

now if the queue is smaller than 500 message, the receiveMessage() (I also tested with a timeout) is never stopping listening indefinitevely the queue for new messages.

How can be sure to get the right number of message?

If I do not use selector, I can easily set the limit to the queue size (calculated before) but with selector, there's no way to find how many message would be returned by the calls.

Note that using the JCSMP API is working well, as there is a getNext() method that will return null if no more message have to be processed but I want to know if this is possible in the new Java API.

The sentence from JCMP API page
"You can continue to use this classic Java API to build new messaging applications, however, if you want to use a Java API that utilizes modern interfaces, patterns, and programming models, consider using the Java API."


makes me feel the JCPMP can be deprecated in the future, hence my question.

mpatel

In Java API, have you tried using the MessageQueueBrowser methods receiveMessage(timeOut) or receiveOrElse(supplierOfAlternativeResponse)

https://docs.solace.com/API-Developer-Online-Ref-Documentation/pubsubplus-java/com/solace/messaging/receiver/MessageQueueBrowser.html#receiveMessage-long-

With the receiveMessage(timeOut) when there is no more message, method would return null. Which is similar to JCSMP API  getNext() method returning null.

mpatel

In Java API, have you tried using the MessageQueueBrowser methods receiveMessage(timeOut) or receiveOrElse(supplierOfAlternativeResponse)

https://docs.solace.com/API-Developer-Online-Ref-Documentation/pubsubplus-java/com/solace/messaging/receiver/MessageQueueBrowser.html#receiveMessage-long-

With the receiveMessage(timeOut) when there is no more message, method would return null. Which is similar to JCSMP API  getNext() method returning null.

pruffieux

Yes,

you're right, at the end I just need to check if the message is null and break the loop.

if( message != null ) {
    LOGGER.info("Found a message");
    result.add(queueResultMapper.toMessageDto(message));
}else{
    break;
}