[
https://issues.apache.org/jira/browse/ARTEMIS-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877062#comment-17877062
]
ASF subversion and git services commented on ARTEMIS-5007:
----------------------------------------------------------
Commit 18e6f1a88d2c8770c199cf32df3389a05e4f507f in activemq-artemis's branch
refs/heads/main from Timothy Bish
[ https://gitbox.apache.org/repos/asf?p=activemq-artemis.git;h=18e6f1a88d ]
ARTEMIS-5007 Ensure mirror connection recovers from manual closures
If a user for some reason force closes the local mirror connection SNF
consumer or the actual connection but hasn't stopped the broker connection
itself the connection should recover and rebuild. The fix ensures that if
local connections are closed first then local session resources get freed.
> 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
> Priority: Minor
> 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
