You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@activemq.apache.org by "Shiping Liang (JIRA)" <ji...@apache.org> on 2019/01/18 01:49:00 UTC

[jira] [Updated] (ARTEMIS-2226) MQTT consumer uses ANYCAST routing to consume messages

     [ https://issues.apache.org/jira/browse/ARTEMIS-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Shiping Liang updated ARTEMIS-2226:
-----------------------------------
    Summary: MQTT consumer uses ANYCAST routing to consume messages  (was: Use the wrong key to store Binding)

> MQTT consumer uses ANYCAST routing to consume messages
> ------------------------------------------------------
>
>                 Key: ARTEMIS-2226
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-2226
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>            Reporter: Shiping Liang
>            Priority: Major
>         Attachments: clusterTest.png, mqttTest.png
>
>
>  In the cluster two consumers using the same clientId, subscribe to the same topic on different nodes，MQTT consumers start to consume messages using ANYCAST routing。this will cause to use different keys(use addressName as key or use "clientId+'.'+addressName" as key) to store Binding as below describe.
> Use *_MqttClusterRemoteSubscribeTest_* test. The internal queue name equal addressName (use addressName to save `Binding`).Ii is wrong. As the following test screenshot:
> !clusterTest.png!
> Use _*MQTTTest.testNoMessageReceivedAfterUnsubscribeMQTT*_ test. The internal queue name equal "clientId+'.'+addressName"(use "clientId+'.'+addressName" to save `Binding`). It is good.As the following test screenshot:
>   !mqttTest.png!



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)