Uploaded image for project: 'ActiveMQ Classic'
  1. ActiveMQ Classic
  2. AMQ-2218

Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Not A Problem
    • 5.3.0
    • 5.5.0
    • Broker
    • None
    • Windows XP Professional 2002, Service Pack 2, Intel Pentium D 3ghz, various 1.5 and 1.6 versions of jdk

    Description

      I have written a test case which will demonstrate the following scenarios:

      1. Simple producer driving a queue, simple consumer pulling from the queue.
      2. Simple producer driving a queue, simple consumer pulling from the queue and producing an echo of the original message into the same queue.

      Expected: message delivery should not be interrupted.

      Actual: in scenario 2, eventually (about 500k messages in my environment), the delivery is halted to the consumer.

      Test Output:

      waiting for consumer to pause ... consumer: 0, producer: 0
      waiting for consumer to pause ... consumer: 3738, producer: 29796
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841
      waiting for consumer to pause ... consumer: 9224, producer: 67841

      Attachments

        1. EchoConsumerLoadTest.java
          10 kB
          Jar Lyons

        Activity

          People

            Unassigned Unassigned
            jarbaby Jar Lyons
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: