You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2022/10/04 19:18:00 UTC

[jira] [Commented] (ARTEMIS-3918) Support FQQN + anycast + redistribution

    [ https://issues.apache.org/jira/browse/ARTEMIS-3918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612749#comment-17612749 ] 

ASF subversion and git services commented on ARTEMIS-3918:
----------------------------------------------------------

Commit a02935982e0b577afa3901e628d63394a5a9f1f4 in activemq-artemis's branch refs/heads/2.21.0.jbossorg-x from Justin Bertram
[ https://gitbox.apache.org/repos/asf?p=activemq-artemis.git;h=a02935982e ]

ARTEMIS-3918 support FQQN + anycast + redistribution

When a message is sent to an anycast queue via FQQN on one node of a
cluster and then a consumer is created on that same anycast queue via
FQQN on another node in the cluster the message is not redistributed to
the node with the consumer.

This commit fixes this use-case primarily by including the FQQN info in
the notification messages sent to other nodes in the cluster.

(cherry picked from commit 477111ef4c6d9cfbf0f83ca91222d6169405072f)

downstream: ENTMQBR-6673


> Support FQQN + anycast + redistribution
> ---------------------------------------
>
>                 Key: ARTEMIS-3918
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-3918
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>            Reporter: Justin Bertram
>            Assignee: Justin Bertram
>            Priority: Major
>             Fix For: 2.25.0
>
>          Time Spent: 40m
>  Remaining Estimate: 0h
>
> When sending to and consuming from an FQQN on separate cluster nodes messages are not redistributed. This is fairly easy to reproduce.
> # Create a symmetric cluster of 2 nodes.
> # Start a producer connected to node 1 and send a bunch of messages
>     {noformat}
> $ ./artemis producer --message-count 20 --destination 'myAddress::myQueue' --url tcp://node1:61616{noformat}
> # Start a consumer connected to node 2
>     {noformat}
> $ ./artemis consumer --message-count 20 --destination 'myAddress::myQueue' --url tcp://node2:61616{noformat}
> No message is consumed.



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