Uploaded image for project: 'FUSE Message Broker'
  1. FUSE Message Broker
  2. MB-377

Using small queue prefetch sizes cause all consumers to run as fast as the slowest consumer.

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: 5.0.0.17-fuse, 5.1.0.0-fuse
    • Fix Version/s: 5.0.0.19-fuse
    • Component/s: broker
    • Labels:
      None
    • Environment:

      Servicemix 3.3.1.3 on Windows, probably on all platforms.

      Description

      If you have a JMS producer sending messages to multiple consumers and you have the cacheLevel set to 3 or higher, eventually all consumers will run as slow as the slowest consumer.
      In the attached projects the SA sends messages to a MockOptimizer (JMS consumer) that has two threads. One sleeps for one second and the other sleeps for ten. Initially the thread sleeping for 1 second will consume most of the messages, but towards the end it will start to consume messages every ten seconds as well.

        Gliffy Diagrams

          Attachments

          1. AMQ1866.java
            8 kB
          2. AMQ-1866.patch
            8 kB
          3. ESB-343.zip
            35 kB

            Activity

              People

              • Assignee:
                chirino Hiram Chirino
                Reporter:
                martinmurphy Martin Murphy
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: