ActiveMQ Consume all messages from queue on demand

Question

I have REST service which consumes message from queue. I want to consume message on demand - Give me all messages which are available in queue when rest service is getting called.

I'm using ActiveMQ with Spring. Below are the code which i'm using below code to get the message from queue. First time when i hit the service, i'm getting all the messages which are available in queue but if i further publish few more messages, even though if i'm not hitting service, message are getting subscribed. What could be the reason for this ?

while (true) {
        try {
            message = jmsTemplate.receive("TestQ");
            if (message instanceof TextMessage) {
                try {
                    System.out.println(((TextMessage)     message).getText());
                    msg = ((TextMessage) message).getText();
                } catch (JMSException ex) {
                    throw new RuntimeException(ex);
                }
            } else {
                throw new IllegalArgumentException("Message must be of type TextMessage");
            }

        } catch (Exception ex) {
            break;
        }
    }

score 0 · Answer 1 · edited May 23 '17 at 11:49

0

Always print exceptions. This will help you debug.

Take a look at this - How to use Java JMS with MQseries

edited May 23 '17 at 11:49

Community

1
1

answered Mar 06 '14 at 01:16

NRJ

1,064
3
15
32

score 0 · Answer 2 · answered Mar 06 '14 at 03:04

When you use receive() method to receive message, the thread will block until the message becomes available or until the timeout value is exceeded. This can be found from the Javadoc of JmsTemplate:

This method should be used carefully, since it will block the thread until the message becomes available or until the timeout value is exceeded.

The default timeout value for blocking is RECEIVE_TIMEOUT_INDEFINITE_WAIT. So even though you're not hitting the service, your last session thread will block because of this indefinite wait time. To change the default timeout value, you can set the receive timeout to be

jmsTemplate.setReceiveTimeout(RECEIVE_TIMEOUT_NO_WAIT);

This way it will not block but will immediately terminate if currently there is no message.

ActiveMQ Consume all messages from queue on demand

2 Answers2