Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-1855

Lost messages with dynamic queue in AMQ under certain conditions

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • AMQ 7.2.1.GA
    • AMQ 7.2.0.GA
    • None
    • None
    • Hide
      • Create two RHEL 7 machines with these hostnames: host2.local and host3.local
      • Install on both machines Java 8 and AMQ-7.2.0, attached are the broker configuration folder
        (File "broker1-etc.zip" for host2.local)
        (File "broker2-etc.zip" for host3.local)
      • On machine host3.local, install Interconnect and with all cyrus-sasl packages
        yum install qpid-dispatch-router qpid-dispatch-tools cyrus-sasl*
      • Once installed interconnect, backup directory /etc/qpid-dispatch, and replace with folder qpid-dispatch in zip file "qpid-dispatch.zip"
      • Open ports on firewall-cmd
        8161 62626 for machine: host2.local
        8161 62626 5276 for machine: host3.local
      • Start Interconnect, broker1 and broker2
        In host2.local
        broker1/bin/artemis run
        In host3.local
        broker2/bin/artemis run
        qdrouterd
      • On your local machine,
        unzip producerConsumer.zip
        add host2.local and host3.local, to /etc/hosts
        in producerConsumer/examples there are two scripts, fpr running consumer and producer respectively:
        runConsumer.sh
        runProducer.sh
      • To reproduce problem:
      • Start runProducer.sh
      • Wait producer sents some messages
      • Check Queue in hawtio, should be here
      • Start runConsumer.sh, in another window
      • Wait a while
      • When producer has just sent 10 messages, stop consumer (Ctrl+c in runConsumer.sh window)
      • BUG: Producer keeps sending messages, but queue is gone because of autodelete, it does not appear more in Hawtio
      • Start runConsumer.sh again, it begins to consume messages again, but only messages sent after it starts
      Show
      Create two RHEL 7 machines with these hostnames: host2.local and host3.local Install on both machines Java 8 and AMQ-7.2.0, attached are the broker configuration folder (File "broker1-etc.zip" for host2.local) (File "broker2-etc.zip" for host3.local) On machine host3.local, install Interconnect and with all cyrus-sasl packages yum install qpid-dispatch-router qpid-dispatch-tools cyrus-sasl* Once installed interconnect, backup directory /etc/qpid-dispatch, and replace with folder qpid-dispatch in zip file "qpid-dispatch.zip" Open ports on firewall-cmd 8161 62626 for machine: host2.local 8161 62626 5276 for machine: host3.local Start Interconnect, broker1 and broker2 In host2.local broker1/bin/artemis run In host3.local broker2/bin/artemis run qdrouterd On your local machine, unzip producerConsumer.zip add host2.local and host3.local, to /etc/hosts in producerConsumer/examples there are two scripts, fpr running consumer and producer respectively: runConsumer.sh runProducer.sh To reproduce problem: Start runProducer.sh Wait producer sents some messages Check Queue in hawtio, should be here Start runConsumer.sh, in another window Wait a while When producer has just sent 10 messages, stop consumer (Ctrl+c in runConsumer.sh window) BUG: Producer keeps sending messages, but queue is gone because of autodelete, it does not appear more in Hawtio Start runConsumer.sh again, it begins to consume messages again, but only messages sent after it starts
    • AMQ Broker 1839

      The loss of messages happen in these sequence:

      • Producer creates a dynamic queue, and begins sending messages, in groups of 10, stops for a while after sending a group
      • Messages are shown in Interconnect
      • Consumer gets 99 messages
      • In Hawtio console, we see all 99 messages acknowledged, message count = 0 (Producer is resting).
      • In this moment, Consumer is stopped, and dynamic queue is deleted
      • Producer keeps sending messages (sents 50 more)
      • 50 Messages just sent are shown in Interconnect, but appear nowhere in Hawtio, because the queue is deleted
      • Consumer is started again, dynamic queue appears in hawtio, Producer sends 20 more messages
      • Consumer begins to get messages again, but only the last 20 messages, not the 50 messages sent when Consumer was down

        1. broker1-etc.zip
          12 kB
        2. broker2-etc.zip
          12 kB
        3. producerConsumer.zip
          4.23 MB
        4. qpid-dispatch.zip
          5 kB
        5. update-without-interconnect.zip
          3 kB

              fnigro Francesco Nigro
              rhn-support-anarvaez Alfredo Narvaez
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: