You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Jean-Pascal Briquet (Jira)" <ji...@apache.org> on 2024/08/22 12:30:00 UTC

[jira] [Created] (ARTEMIS-5007) Mirroring consumer does not recover automatically

Jean-Pascal Briquet created ARTEMIS-5007:
--------------------------------------------

             Summary: Mirroring consumer does not recover automatically
                 Key: ARTEMIS-5007
                 URL: https://issues.apache.org/jira/browse/ARTEMIS-5007
             Project: ActiveMQ Artemis
          Issue Type: Bug
          Components: AMQP, Broker
    Affects Versions: 2.36.0
            Reporter: Jean-Pascal Briquet
         Attachments: testBrokerMirrorRecreateConsumer.java

*Context:*
AMQP broker connection and mirroring link enabled between two Artemis nodes

*Current behaviour:*
The mirroring consumer does not recover automatically when it is closed from the administration console/JMX, or if the consumer crashes.
This behaviour differs from the AMQP broker connection that is able to recover automatically if connection is closed or if connectivity fails.

*Workaround:*
Close the AMQP broker connection that was used by the mirroring consumer. The broker connection will be recreated automatically, starting a new mirroring consumer and restoring the replication.

*Expected behaviour:*
If the AMQP broker connection is active, the mirroring consumer should always restart if it stops or if it crashes. And at most one consumer should be present on the mirror/snf queue.
This would provide to consumer a recovery identical to the AMQP broker connection's self-healing feature.

 

*Tests cases:*
Test cases are provided in attachment, to run, add them into the Artemis test class located under: 

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/AMQPReplicaTest.java
 * {color:#00627a}testBrokerMirrorRecreateConsumer() : consumer closed and is never recreated automically{color}
 * {color:#00627a}testBrokerMirrorRecreateConnection() : broker connection closed and automatically recreated. The strange thing is that there is a low chance (10-20%) this test fails because more than 1 consumer will exists on the snf queue after the reconnection.
{color}

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@activemq.apache.org
For additional commands, e-mail: issues-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact