[
https://issues.apache.org/jira/browse/ARTEMIS-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943509#comment-17943509
]
ASF subversion and git services commented on ARTEMIS-5381:
----------------------------------------------------------
Commit dcc1afdbe810d615849d0dd9e9ef5430cb123bdf in activemq-artemis's branch
refs/heads/main from Timothy Bish
[ https://gitbox.apache.org/repos/asf?p=activemq-artemis.git;h=dcc1afdbe8 ]
ARTEMIS-5381 Use FQQN to remove federation address subscription if set
If the remote used an FQQN to define the address and stable subscription for the
address consumer recover the subscription from the FQQN when the remote closes
the consumer due to demand having been removed on the remote for that address.
> auto increment of link name in amqp address federation can lead to missing
> messages on restart
> ----------------------------------------------------------------------------------------------
>
> Key: ARTEMIS-5381
> URL: https://issues.apache.org/jira/browse/ARTEMIS-5381
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: AMQP, Federation
> Affects Versions: 2.39.0
> Reporter: Gary Tully
> Assignee: Timothy A. Bish
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.41.0
>
> Attachments: ARTEMIS-5381.diff
>
> Time Spent: 1h 40m
> Remaining Estimate: 0h
>
> The fix for ARTEMIS-5135 adds an auto increment identity to the link names
> used by address federation consumers.
> this means that they change after a restart, or are order dependent on
> startup. In any event, if there are local durable consumers, and there are
> messages produced while the local broker is stopped, they will exist on the
> original link and won't be pulled on the recreated link after restart.
--
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
