[
Date Prev][
Date Next][
Thread Prev][
Thread Next][
Date Index][
Thread Index]
[
List Home]
|
[mosquitto-dev] Old Messages being replayed on QOS 2
|
I am using Mosquito 1.4.1 broker (CloudMqtt)
We are seeing old messages (weeks old) being replayed when a temporarily disconnected client reconnects.
I have attached the logs
It looks as if the issue is that our shutdown message shutsdown the server before the shutdown message has its PUBCOMP sent.
When the client starts again it receives a number of messages before that shutdown message.
Is this a bug? How can we ensure the shutdown message is processed before terminating? (Using paho-mqtt python)
Thanks
Adam
2016-01-06 00:30:40.000 +11:00,Received PUBCOMP (Mid: 50)
2016-01-06 00:30:40.000 +11:00,Sending PUBREL (Mid: 50)
2016-01-06 00:30:40.000 +11:00,Received PUBREC (Mid: 50)
2016-01-06 00:30:58.000 +11:00,"Sending PUBLISH (dFalse, q2, r0, m51, 'device/251330451944628/status', ... (142 bytes)"
2016-01-06 00:30:58.000 +11:00,Disconnected from MQTT
2016-01-06 00:31:00.000 +11:00,Sending PUBREC (Mid: 5)
2016-01-06 00:31:00.000 +11:00,"Received PUBLISH (d1, q2, r0, m5, 'device/251330451944628', ... (239 bytes)"
2016-01-06 00:31:00.000 +11:00,Sending PUBREC (Mid: 4)
2016-01-06 00:31:00.000 +11:00,"Received PUBLISH (d1, q2, r0, m4, 'device/251330451944628', ... (165 bytes)"
2016-01-06 00:31:00.000 +11:00,Received PUBREL (Mid: 3)
2016-01-06 00:31:00.000 +11:00,Received PUBREL (Mid: 2)
2016-01-06 00:31:00.000 +11:00,Received PUBREL (Mid: 1)
2016-01-06 00:31:00.000 +11:00,"Sending PUBLISH (dTrue, q2, r0, m51, 'device/251330451944628/status', ... (142 bytes)"
2016-01-06 00:31:00.000 +11:00,"Sending PUBLISH (dFalse, q2, r0, m52, 'device/251330451944628/status', ... (139 bytes)"
2016-01-06 00:31:00.000 +11:00,Connected to ******
2016-01-06 00:31:00.000 +11:00,"Received CONNACK (1, 0)"
2016-01-06 00:31:01.000 +11:00,Time disparity of 819474.443422 seconds
2016-01-06 00:31:01.000 +11:00,Received message 4 of type OverrideRemoved sent at 2015-12-27 01:53:07.156792
2016-01-06 00:31:01.000 +11:00,Received PUBREL (Mid: 4)
2016-01-06 00:31:01.000 +11:00,Sending PUBREL (Mid: 51)
2016-01-06 00:31:01.000 +11:00,Received PUBREC (Mid: 51)
2016-01-06 00:31:01.000 +11:00,Sending PUBREL (Mid: 52)
2016-01-06 00:31:01.000 +11:00,Received PUBREC (Mid: 52)
2016-01-06 00:31:01.000 +11:00,Received PUBREL (Mid: 3)
2016-01-06 00:31:01.000 +11:00,Received PUBREL (Mid: 2)
2016-01-06 00:31:01.000 +11:00,Received PUBREL (Mid: 1)
2016-01-06 00:31:01.000 +11:00,Sending PUBREC (Mid: 11)
2016-01-06 00:31:01.000 +11:00,"Received PUBLISH (d0, q2, r0, m11, 'device/251330451944628', ... (239 bytes)"
2016-01-06 00:31:01.000 +11:00,Sending PUBREC (Mid: 10)
2016-01-06 00:31:01.000 +11:00,"Received PUBLISH (d0, q2, r0, m10, 'device/251330451944628', ... (165 bytes)"
2016-01-06 00:31:01.000 +11:00,Sending PUBREC (Mid: 9)
2016-01-06 00:31:01.000 +11:00,"Received PUBLISH (d0, q2, r0, m9, 'device/251330451944628', ... (133 bytes)"
2016-01-06 00:31:01.000 +11:00,Sending PUBREC (Mid: 8)
2016-01-06 00:31:01.000 +11:00,"Received PUBLISH (d0, q2, r0, m8, 'device/251330451944628', ... (143 bytes)"
2016-01-06 00:31:01.000 +11:00,Sending PUBREC (Mid: 7)
2016-01-06 00:31:01.000 +11:00,"Received PUBLISH (d0, q2, r0, m7, 'device/251330451944628', ... (136 bytes)"
2016-01-06 00:31:01.000 +11:00,Sending PUBREC (Mid: 6)
2016-01-06 00:31:01.000 +11:00,"Received PUBLISH (d0, q2, r0, m6, 'device/251330451944628', ... (135 bytes)"
2016-01-06 00:31:08.000 +11:00,Time disparity of 819476.135127 seconds
2016-01-06 00:31:08.000 +11:00,Received message 5 of type OverrideChanged sent at 2015-12-27 01:53:12.304177
2016-01-06 00:31:08.000 +11:00,Received PUBREL (Mid: 5)
2016-01-06 00:31:08.000 +11:00,Sending PUBCOMP (Mid: 4)
2016-01-06 00:31:16.000 +11:00,"Time disparity of 816755.6467 seconds, manually calling NTP. Server: 2015-12-27 02:38:40.567376 Local: 2016-01-05 13:31:16.214329"
2016-01-06 00:31:16.000 +11:00,Received message 6 of type Shutdown sent at 2015-12-27 02:38:40.567376
2016-01-06 00:31:16.000 +11:00,Received PUBREL (Mid: 6)
2016-01-06 00:31:16.000 +11:00,Sending PUBCOMP (Mid: 5)
,
,Started Again
,
2016-01-06 00:56:07.000 +11:00,Connecting to ********
2016-01-06 00:56:07.000 +11:00,Services Started
2016-01-06 00:56:08.000 +11:00,Received PUBCOMP (Mid: 4)
2016-01-06 00:56:08.000 +11:00,Received PUBCOMP (Mid: 3)
2016-01-06 00:56:08.000 +11:00,Sending PUBREL (Mid: 4)
2016-01-06 00:56:08.000 +11:00,Received PUBREC (Mid: 4)
2016-01-06 00:56:08.000 +11:00,Sending PUBREL (Mid: 3)
2016-01-06 00:56:08.000 +11:00,Received PUBREC (Mid: 3)
2016-01-06 00:56:08.000 +11:00,Received SUBACK
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 11)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 10)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 9)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 8)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 7)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 6)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 3)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 2)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 1)
2016-01-06 00:56:08.000 +11:00,Received SUBACK
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 11)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 10)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 9)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 8)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 7)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 6)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 3)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 2)
2016-01-06 00:56:08.000 +11:00,Received PUBREL (Mid: 1)
2016-01-06 00:56:08.000 +11:00,"Sending PUBLISH (dFalse, q2, r0, m4, 'device/251330451944628/status', ... (138 bytes)"
2016-01-06 00:56:08.000 +11:00,Connected to ******
2016-01-06 00:56:08.000 +11:00,"Received CONNACK (1, 0)"
2016-01-06 00:56:08.000 +11:00,"Sending PUBLISH (dFalse, q2, r0, m3, 'server/master', ... (149 bytes)"
2016-01-06 00:56:09.000 +11:00,Received PUBREL (Mid: 1)
2016-01-06 00:56:09.000 +11:00,Sending PUBREC (Mid: 3)
2016-01-06 00:56:09.000 +11:00,"Received PUBLISH (d0, q2, r0, m3, 'device/251330451944628', ... (151 bytes)"
2016-01-06 00:56:09.000 +11:00,Sending PUBREC (Mid: 2)
2016-01-06 00:56:09.000 +11:00,"Received PUBLISH (d0, q2, r0, m2, 'device/251330451944628', ... (123 bytes)"
2016-01-06 00:56:09.000 +11:00,Sending PUBREC (Mid: 1)
2016-01-06 00:56:09.000 +11:00,"Received PUBLISH (d0, q2, r0, m1, 'device/251330451944628', ... (2533 bytes)"
