Github user jbertram commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2466#discussion_r246563323
--- Diff:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTQueueCleanTest.java
---
@@ -0,0
Github user jbertram commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2466#discussion_r246562512
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
---
@@ -3604,4 +3605,14 @@ private
GitHub user onlyMIT reopened a pull request:
https://github.com/apache/activemq-artemis/pull/2466
ARTEMIS-2206 The MQTT consumer reconnection caused the queue to not be
cleâ¦
### Test environment
1. Use 10,000 (9 thousand senders, 1 thousand consumers) MQTT connection on
Github user onlyMIT closed the pull request at:
https://github.com/apache/activemq-artemis/pull/2466
---
Github user onlyMIT commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2466#discussion_r242583621
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
---
@@ -113,32 +113,7 @@
import
Github user onlyMIT commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2466#discussion_r242582946
--- Diff:
artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java
---
Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2466#discussion_r242541448
--- Diff:
artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java
Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2466#discussion_r242540859
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
---
@@ -113,32 +113,7 @@
