1 Reply Latest reply on Sep 16, 2010 1:03 PM by Peter Chandler

    Mixing Slow and Fast Consumers on a topic.

    Peter Chandler Master

      My scenario in ActiveMQ 5.3:


         I have a fast producer/publisher to topic A.

         I have both Fast and Slow Consumers/Subscribers on topic A .


      The behavior I am seeing is that the Producer slows down to match the speed of the slowest Consumer.


      The desired  behavior (what I need help configuring) is: the Producer does not slow down and the slower Consumer(s) just drop older messages. Question: How do I configure this behavior in ActiveMQ?


      Below is what I have tried so far with no luck:

      On the Broker: persistent="false"

      Sender: jms.useAsyncSend="true"


                          <policyEntry topic=">" producerFlowControl="false" memoryLimit="64mb">
                                  <individualDeadLetterStrategy  topicPrefix="deadLetter"></individualDeadLetterStrategy>
                              <!-- How to dispatch the messages -->
                              <!-- which messages to get rid of -->
                              <!-- Keep around 2.5 times the prefetch count for each consumer -->
                                  <prefetchRatePendingMessageLimitStrategy multiplier="2.5"></prefetchRatePendingMessageLimitStrategy>
                              <!--  Keep the last 1000 messages -->
                                  <fixedCountSubscriptionRecoveryPolicy maximumSize="1000"></fixedCountSubscriptionRecoveryPolicy>