onlyMIT commented on issue #2466: ARTEMIS-2206 The MQTT consumer reconnection caused the queue to not be cle… URL: https://github.com/apache/activemq-artemis/pull/2466#issuecomment-455244484 @michaelandrepearce @jbertram I think my RP failures in `org.apache.activemq.artemis.tests.integration.mqtt.imported.MqttClusterRemoteSubscribeTest` is caused by another issue. The issue is when 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。 But two consumers using the same clientId, subscribe to the same topic **on the same node**，the latter consumer connection will cause the former consumer connection to be forcibly closed, Only one consumer will consume the message。 I think that ANYCAST routing should not be triggered if the same clientId is used to subscribe to the same topic in different nodes.this will export using different keys(use addressName as key or use "clientId+'.'+addressName" as key) to store `Binding` As described in [ARTEMIS-2226](https://issues.apache.org/jira/browse/ARTEMIS-2226) . Now I am not sure whether i use this RP to address the issue as above, or create a new RP.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
