cancel
Showing results for 
Search instead for 
Did you mean: 
cancel
Showing results for 
Search instead for 
Did you mean: 

Community Tip - Learn all about PTC Community Badges. Engage with PTC and see how many you can earn! X

Packet loss using MQTT subscribe

dbologna
12-Amethyst

Packet loss using MQTT subscribe

Hello,

we have defined a Thing with MQTT Template, receiving packets from MQTT broker.

Packets are coming and stored in a stream, but sometimes packets are lost.

We know that these packets have been sent from the MQTT broker but we don't find them in the stream.

The packet is received into a JSON property, and the subscription (defined on data change) read the JSON and transform it to store into the stream.

Any idea ? Many thank Dimitri

ACCEPTED SOLUTION

Accepted Solutions
PaiChung
22-Sapphire I
(To:dbologna)

I would then first put messages into an in memory infotable and then have that picked up by a separate service to handle the messages.

you can use the addrow/deleterow to very real time population of the memory queue and unload.

View solution in original post

5 REPLIES 5
PaiChung
22-Sapphire I
(To:dbologna)

how rapidly are these messages coming in at times?

anything with a timestamp within 3 ms will not go into the stream or overwrite the existing entry.

So especially if you are queueing a lot of messages to be processed at once you might run into this issue.

dbologna
12-Amethyst
(To:PaiChung)

H i Thanks.

That's what I found.
What solution can I adopt to avoid losing information.

BR

Dimitri

PaiChung
22-Sapphire I
(To:dbologna)

Either you bulk / cache the incoming messages and process them as 'one' or you may have to force a 3ms pause() before writing the subsequent messages to be certain.

 

dbologna
12-Amethyst
(To:PaiChung)

Hi PaiChung,

packets are submitted from many machines then the we receive then with high frequency.

How can i 'bulk / cache the incoming messages'  in order to avoid to loose packets.

I cannot set a pause because I don't manage the submit on the  Mqtt Broker.

I Just manage only the subscription on Thingworx.

BR 

Dimitri

PaiChung
22-Sapphire I
(To:dbologna)

I would then first put messages into an in memory infotable and then have that picked up by a separate service to handle the messages.

you can use the addrow/deleterow to very real time population of the memory queue and unload.

Announcements


Top Tags