[
https://issues.apache.org/jira/browse/ARTEMIS-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187562#comment-17187562
]
Florian Meister commented on ARTEMIS-2888:
------------------------------------------
Below you can find a trace of one specific MQTT Message. It is published by
"end_to_end_dev" and then gets forwarded to "b4b8135fd3d8446b8612d110d55b4afe"
- via an MQTT subscription. You can see that the topic artemis publishes the
message is including wildcards. It seems it uses the topic filter instead of
the topic name.
{code:java}
Aug 31 10:19:38 chsfslx0108 bash[1256]: 2020-08-31 10:19:38,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(597)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861978264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":592,"badParts":4,"timestamp":1598861978264}}
Aug 31 10:19:38 chsfslx0108 bash[1256]: 2020-08-31 10:19:38,274 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(597)
Aug 31 10:19:38 chsfslx0108 bash[1256]: 2020-08-31 10:19:38,274 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119238)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861978264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":592,"badParts":4,"timestamp":1598861978264}}
{code}
It seems this behaviour is only happening when the queue is in paging mode (or
when there are many messages in it). Currently there are sitting around 90M
Messages in it and the queue is in paging mode. Other topics/queues which are
not in paging mode are working normal.
Below a little bit more logs
{code:java}
Aug 31 10:19:39 chsfslx0108 bash[1256]: 2020-08-31 10:19:39,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(598)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861979264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":593,"badParts":4,"timestamp":1598861979264}}
Aug 31 10:19:39 chsfslx0108 bash[1256]: 2020-08-31 10:19:39,272 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(598)
Aug 31 10:19:39 chsfslx0108 bash[1256]: 2020-08-31 10:19:39,272 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119233)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861979264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":593,"badParts":4,"timestamp":1598861979264}}
Aug 31 10:19:40 chsfslx0108 bash[1256]: 2020-08-31 10:19:40,265 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(599)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861980264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":594,"badParts":4,"timestamp":1598861980264}}
Aug 31 10:19:40 chsfslx0108 bash[1256]: 2020-08-31 10:19:40,279 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(599)
Aug 31 10:19:40 chsfslx0108 bash[1256]: 2020-08-31 10:19:40,279 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119229)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861980264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":594,"badParts":4,"timestamp":1598861980264}}
Aug 31 10:19:41 chsfslx0108 bash[1256]: 2020-08-31 10:19:41,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(600)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861981264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":595,"badParts":4,"timestamp":1598861981264}}
Aug 31 10:19:41 chsfslx0108 bash[1256]: 2020-08-31 10:19:41,283 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(600)
Aug 31 10:19:41 chsfslx0108 bash[1256]: 2020-08-31 10:19:41,284 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119225)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861981264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":595,"badParts":4,"timestamp":1598861981264}}
Aug 31 10:19:42 chsfslx0108 bash[1256]: 2020-08-31 10:19:42,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(601)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861982264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":596,"badParts":4,"timestamp":1598861982264}}
Aug 31 10:19:42 chsfslx0108 bash[1256]: 2020-08-31 10:19:42,274 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(601)
Aug 31 10:19:42 chsfslx0108 bash[1256]: 2020-08-31 10:19:42,274 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119221)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861982264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":596,"badParts":4,"timestamp":1598861982264}}
Aug 31 10:19:43 chsfslx0108 bash[1256]: 2020-08-31 10:19:43,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(602)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861983264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":597,"badParts":4,"timestamp":1598861983264}}
Aug 31 10:19:43 chsfslx0108 bash[1256]: 2020-08-31 10:19:43,278 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(602)
Aug 31 10:19:43 chsfslx0108 bash[1256]: 2020-08-31 10:19:43,278 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119217)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861983264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":597,"badParts":4,"timestamp":1598861983264}}
Aug 31 10:19:44 chsfslx0108 bash[1256]: 2020-08-31 10:19:44,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(603)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861984265,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":598,"badParts":4,"timestamp":1598861984265}}
Aug 31 10:19:44 chsfslx0108 bash[1256]: 2020-08-31 10:19:44,275 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(603)
Aug 31 10:19:44 chsfslx0108 bash[1256]: 2020-08-31 10:19:44,275 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119213)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861984265,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":598,"badParts":4,"timestamp":1598861984265}}
Aug 31 10:19:45 chsfslx0108 bash[1256]: 2020-08-31 10:19:45,266 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(604)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861985264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":599,"badParts":4,"timestamp":1598861985264}}
Aug 31 10:19:45 chsfslx0108 bash[1256]: 2020-08-31 10:19:45,274 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(604)
Aug 31 10:19:45 chsfslx0108 bash[1256]: 2020-08-31 10:19:45,274 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119209)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861985264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":599,"badParts":4,"timestamp":1598861985264}}
Aug 31 10:19:46 chsfslx0108 bash[1256]: 2020-08-31 10:19:46,265 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): IN <<
PUBLISH(605)
topic=8414493f-22a5-47af-a5f6-8ebfd63d51d7/from-smart-acquisition-device/part-count/event,
qos=AT_LEAST_ONCE, retain=false, dup=false,
payload={"timestamp":1598861986264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":600,"badParts":4,"timestamp":1598861986264}}
Aug 31 10:19:46 chsfslx0108 bash[1256]: 2020-08-31 10:19:46,277 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt] MQTT(end_to_end_dev): OUT >>
PUBACK(605)
Aug 31 10:19:46 chsfslx0108 bash[1256]: 2020-08-31 10:19:46,277 TRACE
[org.apache.activemq.artemis.core.protocol.mqtt]
MQTT(b4b8135fd3d8446b8612d110d55b4afe): OUT >> PUBLISH(-2123119205)
topic=+/from-smart-acquisition-device/part-count/event, qos=AT_MOST_ONCE,
retain=false, dup=false,
payload={"timestamp":1598861986264,"deviceId":"8414493f-22a5-47af-a5f6-8ebfd63d51d7","partCountData":{"totalParts":600,"badParts":4,"timestamp":1598861986264}}
{code}
> MQTT spec violation when subscribed to wildcard topic
> -----------------------------------------------------
>
> Key: ARTEMIS-2888
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2888
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: MQTT
> Affects Versions: 2.14.0
> Environment: *Message Producer:*
> MQTTnet Client
> published Message to
> 0e5ed50e-ccea-4a42-8c3e-db0e2780222b/from-smart-acquisition-device/machine-state/event/off
>
> *Message Consumer:*
> MQTT Paho Java Client, also tested with HiveMQ Java Client.
> Subscribed to +/from-smart-acquisition-device/machine-state/event/off
> Reporter: Florian Meister
> Priority: Major
> Attachments: image-2020-08-27-12-37-01-479.png
>
>
> Sometimes the topic name of published messages contains the topic filter
> instead of the topic name.
> This is neither correct nor allowed in the MQTT 3.1.1 specification:
> [http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Toc398718106]
>
> Below a screenshot of an example MQTT Packet sent from the Artemis Broker
> !image-2020-08-27-12-37-01-479.png!
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
