Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-444

Stuck messages in a network of brokers that don't get dispatched to consumer

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: JBoss A-MQ 6.0
    • Fix Version/s: JBoss A-MQ 6.1
    • Component/s: broker
    • Labels:
      None
    • Environment:

      ActiveMQ 5.8.0, JDBC persistence adapter

      Description

      Its possible to get a broker (that is part of a full mesh network) into a state where a small amount of messages seem to be stuck on the broker's queue and don't get dispatched to any consumer.
      When trying to browse the queue using JMX no messages are returned but the JMX QueueSize statistic reports one or a few messages.
      In addition (as JDBC persistence is used) the corresponding database has the same amount of messages still residing in the activemq_msgs table.This problem is tricky to reproduce. However the attached JUnit test should help. It may not reproduce it on every test run though.
      The broker's network configuration already uses replayWhenNoConsumers=true, enableAudit=false, networkTTL=9999, optimizedDispatch=true so that messages can freely get passed around in the network.
      The above three settings should already avoid messages getting stuck on one broker or getting discarded as duplicates. Still there seems to be another problem.

        Gliffy Diagrams

          Attachments

          1. JUnitTest.tgz
            19 kB
            Torsten Mielke
          2. UnitTest.v2.tgz
            19 kB
            Torsten Mielke

            Issue Links

              Activity

                People

                • Assignee:
                  garytully Gary Tully
                  Reporter:
                  mielket Torsten Mielke
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  5 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: