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

Messages are not deleted in the mirror broker if they were distributed from the main to another broker in the cluster

    XMLWordPrintable

Details

    Description

      When testing Mirroring, I found that it works unstable for brokers that are in a cluster. Messages are not deleted in the mirror broker if they were distributed (initial distribution and redistribution too) from the main to another broker in the cluster.

      I have the following scheme, brokers A1 and A2 into clusters and A1 has mirror B1.

      Steps

      1. Create 3 brokers (A1, A2, B1) with default user (root) and password (root) by artemis create
      2. Replace their configuration with the configuration from the attachment (brokerA1.xml and etc.)
      3. Run this brokers artemis run
      4. Run ArtemisConsumer from maven project ArtemisClusterMirror.rar in attachment
      5. Run ArtemisProducer from maven project ArtemisClusterMirror.rar in attachment
      6. Wait for the producer to finish
      7. Turn off consumer
      8. Compare the number of messages queue Q1 in brokers A1 and B1

      Expected Behavior:

      The number of messages in the queue Q1 is the same (0), it is empty

      Received Behavior:

      The queue Q1 in mirror broker B1 contains 50 messages that were sent by the producer. There were no signals to delete these messages from broker A1 when moving them to another cluster broker A2 (with consumer). Screenshots in attachment.

      It is also not clear why the internal cluster queues with the notif prefix are mirrored, in theory they should not. They also often contain messages that are not in the main broker.



      Attachments

        Issue Links

          Activity

            People

              csuconic@redhat.com Clebert Suconic
              rh-messaging-ci Messaging CI
              Oleg Sushchenko Oleg Sushchenko
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: