Uploaded image for project: 'ActiveMQ Artemis'
  1. ActiveMQ Artemis
  2. ARTEMIS-2649

Auto-create DLQ message loss when moving messages between destinations

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.12.0
    • 2.13.0
    • Broker
    • None
    • Centos 7 container in OKD with Java 8.

    Description

      jbertram, first of all thanks a lot for ARTEMIS-2587 implementation.
      This was a must for me to switch to Artemis.
      In past I have even tried to implement it in Artermis, but having no previous experience with it, only with your PR I understood how nicely and easily it can be implemented and how much I have overcomplicated it.

      So I am testing 2.12.0 snapshot as I am really interested in work done under ARTEMIS-2587.
      I am connecting using open wire protocol using camel-jms component, having replaced old AMQ5 with Artermis.

      On failed consumption, I can see queue being created under DLQ address with multicast and filter _AMQ_ORIG_ADDRESS = 'some.queue'.
      However it is empty and message is lost.

      Reproduction scenario:

      1. Sending message to address A
      2. Moving message from A queue to B using web console move function
      3. Consuming from B and failing consumption

      Observed state:

      1. Queue is being created
      2. Message is lost and logs are not indicating anything

      As a result this message being moved from A to be B queue, the header "_AMQ_ORIG_ADDRESS" has value "A" instead of "B" and therefore it does not match the filter "B" and is getting lost.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              nannou9 Piotr Klimczak
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 4h
                  4h