[
https://issues.apache.org/jira/browse/ARTEMIS-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy A. Bish updated ARTEMIS-5007:
-------------------------------------
Affects Version/s: 2.37.0
> 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, 2.37.0
> Reporter: Jean-Pascal Briquet
> Assignee: Timothy A. Bish
> Priority: Minor
> Fix For: 2.38.0
>
> Attachments: testBrokerMirrorRecreateConsumer.java
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> *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: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
