[
https://issues.apache.org/jira/browse/ARTEMIS-2206?focusedWorklogId=186770&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-186770
]
ASF GitHub Bot logged work on ARTEMIS-2206:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 18/Jan/19 08:08
Start Date: 18/Jan/19 08:08
Worklog Time Spent: 10m
Work Description: 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]
Issue Time Tracking
-------------------
Worklog Id: (was: 186770)
Time Spent: 2h 10m (was: 2h)
> The MQTT consumer reconnection caused the queue to not be cleared and throw a
> NullPointerException exception
> ------------------------------------------------------------------------------------------------------------
>
> Key: ARTEMIS-2206
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2206
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: MQTT
> Affects Versions: 2.6.3
> Environment: # Use 10,000 (9 thousand senders, 1 thousand consumers)
> MQTT connection on one server to test Artemis, set the 'cleanSession'
> property to true；
> # MQTT client: paho 1.2.0;
> # Server: CPU Cores:32, Mem:64G, SSD:250G, HDD:1T
> Reporter: Shiping Liang
> Priority: Major
> Attachments: image-2018-12-18-18-28-59-540.png
>
> Time Spent: 2h 10m
> Remaining Estimate: 0h
>
> *Issue 1*
> Artemis broker has the following exception log:
> {{[Thread-0
> (ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=fb358579-feb3-11e8-bc7c-141877a7fd13-1409545055)]
> 17:27:59,035 WARN [org.apache.activemq.artemis.utils.actors.OrderedExecutor]
> null: java.lang.NullPointerException at
> org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolManager.isClientConnected(MQTTProtocolManager.java:182)
> [:] at
> org.apache.activemq.artemis.core.protocol.mqtt.MQTTConnectionManager.disconnect(MQTTConnectionManager.java:150)
> [:] at
> org.apache.activemq.artemis.core.protocol.mqtt.MQTTFailureListener.connectionFailed(MQTTFailureListener.java:37)
> [:] at
> org.apache.activemq.artemis.core.protocol.mqtt.MQTTConnection.fail(MQTTConnection.java:147)
> [:] at
> org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.issueFailure(RemotingServiceImpl.java:561)
> [:] at
> org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl.connectionDestroyed(RemotingServiceImpl.java:542)
> [:] at
> org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor$Listener.connectionDestroyed(NettyAcceptor.java:858)
> [:] at
> org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.lambda$channelInactive$0(ActiveMQChannelHandler.java:83)
> [:] at
> org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42)
> [:] at
> org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31)
> [:] at
> org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66)
> [:] at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> [rt.jar:1.8.0_101] at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> [rt.jar:1.8.0_101] at
> org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
> [:]}}
> *Issue 2*
> After closing all client connections, 64 queues were not cleaned up。
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
