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/08/19 20:43: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=17582029#comment-17582029 ] 

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

Commit 86db53da9acb96ed81b38fe3962aa0532047898a in activemq-artemis's branch refs/heads/main from Justin Bertram
[ https://gitbox.apache.org/repos/asf?p=activemq-artemis.git;h=86db53da9a ]

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.


> 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
>          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)