stefanom opened a new pull request, #4684:
URL: https://github.com/apache/activemq-artemis/pull/4684
Artemis currently fails to cleanup federated queues after consumers
disconnect from an address.
This happens because the `remoteQueueConsumer` counter is incremented many
more times than the number of consumers. This mismatch prevents proper cleanup
in the `removeRemoteConsumer()` method below because the `if
(remoteQueueConsumer.decrementCount() <= 0) {` is never invoked.
I have manually validated this change with a fully connected federation of 3
regions using MQTT publishers and subscribers and auto-delete enabled on the
federation: when the subscriber leaves, the local queue is eliminated
immediately and the federation queues (all 6) are closed and removed after a
few minutes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
