[
https://issues.apache.org/jira/browse/ARTEMIS-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shiping Liang updated ARTEMIS-2226:
-----------------------------------
Description:
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!
was:
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。
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!
> Use the wrong key to store Binding
> ----------------------------------
>
> 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)
