Count number of messages in a JMS queue

Question

What is the best way to go over a JMS queue and get all the messages in it?

How can count the number of messages in a queue?

Thanks.

You can use jmx in some cases (depends of JMS implementation) — user1516873, Nov 28 '12 at 11:43
i see, `activemq` tag. Example for ActiveMQ http://java.dzone.com/articles/managing-activemq-jmx-apis — user1516873, Nov 28 '12 at 11:52

score 15 · Answer 1 · answered Feb 28 '17 at 18:47

15

Using JmsTemplate

public int getMessageCount(String messageSelector)
{
    return jmsTemplate.browseSelected(messageSelector, new BrowserCallback<Integer>() {
        @Override
        public Integer doInJms(Session s, QueueBrowser qb) throws JMSException
        {
            return Collections.list(qb.getEnumeration()).size();
        }
    });
}

answered Feb 28 '17 at 18:47

Aaron G.

377
3
6

2

For the sake of completeness: this is for users of the Spring framework. – Steffen Harbich Jun 25 '18 at 14:29
I have found an issue with this where the queue size sometimes returns 0, which for our use case, fails the job, no idea why, but has anybody else had reliability issues when using this? – Zohaib Khan Oct 09 '20 at 13:21
can i get the dequeued msg count from jmstemplate? – gifpif Feb 05 '21 at 16:44

score 8 · Answer 2 · edited Aug 28 '14 at 08:56

8

This is how you can count No of Messages in a Queue

public static void main(String[] args) throws Exception
    {
        // get the initial context
        InitialContext ctx = new InitialContext();

        // lookup the queue object
        Queue queue = (Queue) ctx.lookup("queue/queue0");

        // lookup the queue connection factory
        QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.
            lookup("queue/connectionFactory");

        // create a queue connection
        QueueConnection queueConn = connFactory.createQueueConnection();

        // create a queue session
        QueueSession queueSession = queueConn.createQueueSession(false,
            Session.AUTO_ACKNOWLEDGE);

        // create a queue browser
        QueueBrowser queueBrowser = queueSession.createBrowser(queue);

        // start the connection
        queueConn.start();

        // browse the messages
        Enumeration e = queueBrowser.getEnumeration();
        int numMsgs = 0;

        // count number of messages
        while (e.hasMoreElements()) {
            Message message = (Message) e.nextElement();
            numMsgs++;
        }

        System.out.println(queue + " has " + numMsgs + " messages");

        // close the queue connection
        queueConn.close();
    }

edited Aug 28 '14 at 08:56

Henrik Aasted Sørensen

6,966
11
51
60

answered Nov 28 '12 at 11:33

sunleo

10,589
35
116
196

I actually ran this example and for some reason the messeage count shows 400 when i have 5000 messeages on queue – Michael A Nov 28 '12 at 11:35
how do you say that you have 5000 messages in a queue. – sunleo Nov 28 '12 at 11:38
I see it physiclly on my ActiveMQ console – Michael A Nov 28 '12 at 11:40
you send it in a single execution or multiple times , If tried by multiple times ActiveMQ was running or not while you do check. – sunleo Nov 28 '12 at 11:42
my receiver receives amoun of messseages as the count of messeages get – Michael A Nov 28 '12 at 12:13
problem may be your receiver receives messages before you get count. So go and stop the receiver and send using sender and count no of messages.you will get it. – sunleo Nov 28 '12 at 12:24
is this applicable for JBoss 6.4.1 JMS queue? – Duncan O. N. Apr 30 '19 at 07:21
I have around 5000 messages in ActiveMQ, So below code taking time to count. Is there any other way to count ?? `while (e.hasMoreElements()) { Message message = (Message) e.nextElement(); numMsgs++; }` – Bhaumik Sathvara Aug 20 '20 at 16:42
can i get the dequeued msg count from jmstemplate? – gifpif Feb 05 '21 at 16:45

score 7 · Answer 3 · answered Jan 08 '20 at 08:51

Java 8 & Spring Boot

   public int countPendingMessages(String destination) {
    // to an Integer because the response of .browse may be null
    Integer totalPendingMessages = this.jmsTemplate.browse(destination, (session, browser) -> Collections.list(browser.getEnumeration()).size());

    return totalPendingMessages == null ? 0 : totalPendingMessages;
   }

Count number of messages in a JMS queue

3 Answers3

Linked