[ 
https://issues.apache.org/jira/browse/ARTEMIS-3753?focusedWorklogId=753944&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-753944
 ]

ASF GitHub Bot logged work on ARTEMIS-3753:
-------------------------------------------

                Author: ASF GitHub Bot
            Created on: 07/Apr/22 10:03
            Start Date: 07/Apr/22 10:03
    Worklog Time Spent: 10m 
      Work Description: iliya-gr commented on PR #4012:
URL: 
https://github.com/apache/activemq-artemis/pull/4012#issuecomment-1091473831

   I have added integration test for this




Issue Time Tracking
-------------------

    Worklog Id:     (was: 753944)
    Time Spent: 40m  (was: 0.5h)

> Messages are not deleted in the mirror broker if they were distributed from 
> the main to another broker in the cluster
> ---------------------------------------------------------------------------------------------------------------------
>
>                 Key: ARTEMIS-3753
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-3753
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>          Components: AMQP
>    Affects Versions: 2.19.1, 2.21.0
>         Environment: JDK 8
> JDK 11
> Windows 10
> Ubuntu 20.04
>            Reporter: Mikhail Lukyanov
>            Priority: Major
>         Attachments: ArtemisClusterMirror.rar, brokerA1.xml, brokerA2.xml, 
> brokerB1.xml, image-2022-04-01-18-04-36-472.png, 
> image-2022-04-01-18-04-42-130.png, image-2022-04-01-18-05-12-973.png, 
> image-2022-04-01-18-05-27-639.png
>
>          Time Spent: 40m
>  Remaining Estimate: 0h
>
> When testing 
> [Mirroring|https://activemq.apache.org/components/artemis/documentation/latest/amqp-broker-connections.html#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_*|https://activemq.apache.org/components/artemis/documentation/latest/clusters.html]
>  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*
> # Create 3 brokers (A1, A2, B1) with default user (root) and password (root) 
> by _artemis create_
> # Replace their configuration with the configuration from the attachment 
> (brokerA1.xml and etc.)
> # Run this brokers _artemis run_
> # Run ArtemisConsumer from maven project ArtemisClusterMirror.rar  in 
> attachment
> # Run ArtemisProducer from maven project ArtemisClusterMirror.rar in 
> attachment
> # Wait for the producer to finish
> # Turn off consumer
> # 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.
>  !image-2022-04-01-18-04-42-130.png! 
>  !image-2022-04-01-18-05-12-973.png! 
>  !image-2022-04-01-18-05-27-639.png! 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to