Throttling JMS Ques in Spring

Posted on 2008-06-12
Last Modified: 2008-06-17
I am developing an app that uses JMS ques in Spring. The app runs on a JBoss server. The ques are asynchronous and I am placing several messages on the que. The problem is I only want to process a couple of messages at a time. Does anyone know how I can set the que/listener so that only a few messages get sent to the listener, those messages get processed, then another couple of messages get sent to the listener and so on until Im out of messages?
Question by:texastemplar
  • 2
  • 2

Accepted Solution

manuel_m earned 500 total points
ID: 21773068
If you are using a listener to get the messages the listener will receive as many messages as he can get.
You have to receive the messages by your own.

final String YOUR_QUEUE = "queue/testQueue";

    Context         ctx      = null;

    QueueConnection connect  = null;

    QueueSession    session  = null;

    Queue           queue    = null;

    QueueReceiver   receiver = null;

    try {

      ctx = new InitialContext();

      QueueConnectionFactory fact = (QueueConnectionFactory)

                                    ctx.lookup( "ConnectionFactory" );

      connect = fact.createQueueConnection();

      session = connect.createQueueSession( false, Session.AUTO_ACKNOWLEDGE );

      try {

        queue = (Queue) ctx.lookup( YOUR_QUEUE );

      } catch( NameNotFoundException ex ) {

        queue = session.createQueue( YOUR_QUEUE );

        ctx.bind( YOUR_QUEUE, queue );


      receiver = session.createReceiver( queue );


      // get only 10 messages

      for( int i=0; i<10; i++ ) {

        // set timeout to 1000 ms per message

        TextMessage msg = (TextMessage) receiver.receive( 1000 );

        if( null != msg ) {

          System.out.println( msg.getText() );

          // acknowledge the message so it is out of the queue




    } finally {

      try { if( null != receiver ) receiver.close(); } catch( Exception ex ) {}

      try { if( null != session  ) session.close();  } catch( Exception ex ) {}

      try { if( null != connect  ) connect.close();  } catch( Exception ex ) {}

      try { if( null != ctx      ) ctx.close();      } catch( Exception ex ) {}


Open in new window


Author Comment

ID: 21780665
Im trying to slow down the queue so it doesnt send all of the messages to the receivers at once. Possibly a pause between each message or have the queue pass a certain number of messages, then pause, then pass more messages. Im also using Spring to interact with the queues. Can you throttle the queue using Spring? Im thinking that maybe there is a parameter I can place in the spring.xml config file to limit the speed that the queue passes messages. Perhaps there is some spring code I can use to slow things down?

Expert Comment

ID: 21781725
The only thing I can point to are these websites. There is a configuration example in "19.6 JMS Namespace Support" before "Table 19.3. Attributes of the JMS <jca-listener-container/> element" where you can set a prefetch parameter. With this parameter the consumer prefetches the given number of messages and waits for acknowlege (if a TransactionManager is set).

I hope this helps. Otherwise I see no possibility to slow things down with spring.


Author Comment

ID: 21806858
I solved my problem. There is a parameter you can set in the messagelistener container defined in the spring xml file called concurrentConsumers. This limits the number of consumers. Then in each consumer use thread.sleep to slow its consumption of messages.

Featured Post

Threat Intelligence Starter Resources

Integrating threat intelligence can be challenging, and not all companies are ready. These resources can help you build awareness and prepare for defense.

Join & Write a Comment

Suggested Solutions

Title # Comments Views Activity
java continue statement 10 72
Updating Java 9 87
XML Paring  Error - Premature end of file. 7 55
mapAB Challlenge 35 85
This was posted to the Netbeans forum a Feb, 2010 and I also sent it to Verisign. Who didn't help much in my struggles to get my application signed. ------------------------- Start The idea here is to target your cell phones with the correct…
Introduction This article is the last of three articles that explain why and how the Experts Exchange QA Team does test automation for our web site. This article covers our test design approach and then goes through a simple test case example, how …
The viewer will learn how to implement Singleton Design Pattern in Java.
This tutorial will introduce the viewer to VisualVM for the Java platform application. This video explains an example program and covers the Overview, Monitor, and Heap Dump tabs.

708 members asked questions and received personalized solutions in the past 7 days.

Join the community of 500,000 technology professionals and ask your questions.

Join & Ask a Question

Need Help in Real-Time?

Connect with top rated Experts

15 Experts available now in Live!

Get 1:1 Help Now