Skip to main content


Eclipse Community Forums
Forum Search:

Search      Help    Register    Login    Home
Home » Eclipse Projects » Mosquitto » Broker not sending all retained messages(200 topics updated in broker, with retained messages. When client connects, broker only sends 120 messages, not 200)
Broker not sending all retained messages [message #1856379] Wed, 07 December 2022 23:50 Go to next message
Garrett Brennan is currently offline Garrett BrennanFriend
Messages: 4
Registered: December 2022
Junior Member
Hi

This is my first time using this forum.


---------------
Set Up
---------------


I installed Mosquitto v1.6.9 on a Linux machine (which runs inside a virtual machine).
I have two clients.

Client A publishes one message to each of 200 topics. These messages are set with QoS = 1.
Using MQTT Explorer, I can verify that all 200 messages were received by the broker.
Client B connects, and subscribes to all topics.
The broker sends the first 120 topic messages, and not the remaining 80.


-------------------------------------------------------------
Additional information / Things I have tried
-------------------------------------------------------------


ONE

I have tried this with QoS=1, and QoS=2

- same result

TWO

I added the following line to my local config file (even though I know the default should be 1000, but I just wanted to see if there would be any change):

max_queued_messages = 250

- same result

THREE


Then I added another line

max_inflight_messages 1

- same result

FOUR

I viewed the mosquito broker's PUBLISH and PUBACK messages, and verified that
(a) all 200 messages are sent by Client A with retain flag true, and
(b) that only 120 messages are published to Client B when it logs on.

- I have pasted an example of this at the end of this post

FIVE

I testing the same scenario (200 topics) on some of the public/free MQTT brokers:

HiveMQ (broker.hivemq.com) Client B got all 200 messages
MQTTHQ (public.mqtthq.com) Client B got all 200 messages
EMQX (broker.emqx.io) Client B only got 42 messages

So I am seeing something similar from the EMQX public broker


QUESTION


Can any see what I might be missing?

Thank you
Garrett


---------------------------------------------------------------------------
Example of PUBLISH messages received by broker from Client A
---------------------------------------------------------------------------


Received PUBLISH from my_publisher (d0, q2, r1, m61962, 'ui/ui120/a', ... (119 bytes))
Received PUBLISH from my_publisher (d0, q2, r1, m61962, 'ui/ui121/a', ... (119 bytes))
Received PUBLISH from my_publisher (d0, q2, r1, m61962, 'ui/ui122/a', ... (119 bytes))
Received PUBLISH from my_publisher (d0, q2, r1, m61962, 'ui/ui123/a', ... (119 bytes))


---------------------------------------------------------------------------
Example of PUBLISH to Client B, and PUBACKs back from Client B
---------------------------------------------------------------------------


New client connected from xxx.xxx.xxx.xx as my_client' (p2, c0, k0).
No will message specified.
Sending CONNACK to my_client' (1, 0)
Sending PUBLISH to my_client' (d1, q1, r0, m2612, 'ui/ui001/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2613, 'ui/ui002/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2614, 'ui/ui003/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2615, 'ui/ui004/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2616, 'ui/ui005/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2617, 'ui/ui006/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2618, 'ui/ui007/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2619, 'ui/ui008/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2620, 'ui/ui009/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2621, 'ui/ui010/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2622, 'ui/ui011/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2623, 'ui/ui012/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2624, 'ui/ui013/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2625, 'ui/ui014/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2626, 'ui/ui015/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2627, 'ui/ui016/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2628, 'ui/ui017/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2629, 'ui/ui018/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2630, 'ui/ui019/a', ... (119 bytes))
Sending PUBLISH to my_client' (d1, q1, r0, m2631, 'ui/ui020/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2632, 'ui/ui021/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2633, 'ui/ui022/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2634, 'ui/ui023/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2635, 'ui/ui024/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2636, 'ui/ui025/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2637, 'ui/ui026/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2638, 'ui/ui027/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2639, 'ui/ui028/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2640, 'ui/ui029/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2641, 'ui/ui030/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2642, 'ui/ui031/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2643, 'ui/ui032/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2644, 'ui/ui033/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2645, 'ui/ui034/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2646, 'ui/ui035/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2647, 'ui/ui036/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2648, 'ui/ui037/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2649, 'ui/ui038/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2650, 'ui/ui039/a', ... (119 bytes))
Sending PUBLISH to my_client' (d0, q1, r0, m2651, 'ui/ui040/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2612, RC:0)
Received PUBACK from my_client' (Mid: 2613, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2652, 'ui/ui041/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2614, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2653, 'ui/ui042/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2615, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2654, 'ui/ui043/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2616, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2655, 'ui/ui044/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2617, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2656, 'ui/ui045/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2618, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2657, 'ui/ui046/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2619, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2658, 'ui/ui047/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2620, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2659, 'ui/ui048/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2621, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2660, 'ui/ui049/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2622, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2661, 'ui/ui050/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2623, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2662, 'ui/ui051/a', ... (117 bytes))
Received PUBACK from my_client' (Mid: 2624, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2663, 'ui/ui052/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2625, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2664, 'ui/ui053/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2626, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2665, 'ui/ui054/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2627, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2666, 'ui/ui055/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2628, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2667, 'ui/ui056/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2629, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2668, 'ui/ui057/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2630, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2669, 'ui/ui058/a', ... (118 bytes))
Received PUBACK from my_client' (Mid: 2631, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2670, 'ui/ui059/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2632, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2671, 'ui/ui060/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2633, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2672, 'ui/ui061/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2634, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2673, 'ui/ui062/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2635, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2674, 'ui/ui063/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2636, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2675, 'ui/ui064/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2637, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2676, 'ui/ui065/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2638, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2677, 'ui/ui066/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2639, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2678, 'ui/ui067/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2640, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2679, 'ui/ui068/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2641, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2680, 'ui/ui069/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2642, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2681, 'ui/ui070/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2643, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2682, 'ui/ui071/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2644, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2683, 'ui/ui072/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2645, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2684, 'ui/ui073/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2646, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2685, 'ui/ui074/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2647, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2686, 'ui/ui075/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2648, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2687, 'ui/ui076/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2649, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2688, 'ui/ui077/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2650, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2689, 'ui/ui078/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2651, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2690, 'ui/ui079/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2652, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2691, 'ui/ui080/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2653, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2692, 'ui/ui081/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2654, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2693, 'ui/ui082/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2655, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2694, 'ui/ui083/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2656, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2695, 'ui/ui084/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2657, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2696, 'ui/ui085/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2658, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2697, 'ui/ui086/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2659, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2698, 'ui/ui087/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2660, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2699, 'ui/ui088/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2661, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2700, 'ui/ui089/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2662, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2701, 'ui/ui090/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2663, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2702, 'ui/ui091/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2664, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2703, 'ui/ui092/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2665, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2704, 'ui/ui093/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2666, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2705, 'ui/ui094/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2667, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2706, 'ui/ui095/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2668, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2707, 'ui/ui096/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2669, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2708, 'ui/ui097/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2670, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2709, 'ui/ui098/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2671, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2710, 'ui/ui099/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2672, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2711, 'ui/ui100/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2673, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2712, 'ui/ui101/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2674, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2713, 'ui/ui102/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2675, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2714, 'ui/ui103/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2676, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2715, 'ui/ui104/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2677, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2716, 'ui/ui105/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2678, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2717, 'ui/ui106/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2679, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2718, 'ui/ui107/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2680, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2719, 'ui/ui108/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2681, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2720, 'ui/ui109/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2682, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2721, 'ui/ui110/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2683, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2722, 'ui/ui111/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2684, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2723, 'ui/ui112/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2685, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2724, 'ui/ui113/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2686, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2725, 'ui/ui114/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2687, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2726, 'ui/ui115/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2688, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2727, 'ui/ui116/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2689, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2728, 'ui/ui117/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2690, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2729, 'ui/ui118/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2691, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2730, 'ui/ui119/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2692, RC:0)
Sending PUBLISH to my_client' (d0, q1, r0, m2731, 'ui/ui120/a', ... (119 bytes))
Received PUBACK from my_client' (Mid: 2693, RC:0)
Received PUBACK from my_client' (Mid: 2694, RC:0)
Received PUBACK from my_client' (Mid: 2695, RC:0)
Received PUBACK from my_client' (Mid: 2696, RC:0)
Received PUBACK from my_client' (Mid: 2697, RC:0)
Received PUBACK from my_client' (Mid: 2698, RC:0)
Received PUBACK from my_client' (Mid: 2699, RC:0)
Received PUBACK from my_client' (Mid: 2700, RC:0)
Received PUBACK from my_client' (Mid: 2701, RC:0)
Received PUBACK from my_client' (Mid: 2702, RC:0)
Received PUBACK from my_client' (Mid: 2703, RC:0)
Received PUBACK from my_client' (Mid: 2704, RC:0)
Received PUBACK from my_client' (Mid: 2705, RC:0)
Received PUBACK from my_client' (Mid: 2706, RC:0)
Received PUBACK from my_client' (Mid: 2707, RC:0)
Received PUBACK from my_client' (Mid: 2708, RC:0)
Received PUBACK from my_client' (Mid: 2709, RC:0)
Received PUBACK from my_client' (Mid: 2710, RC:0)
Received PUBACK from my_client' (Mid: 2711, RC:0)
Received PUBACK from my_client' (Mid: 2712, RC:0)
Received PUBACK from my_client' (Mid: 2713, RC:0)
Received PUBACK from my_client' (Mid: 2714, RC:0)
Received PUBACK from my_client' (Mid: 2715, RC:0)
Received PUBACK from my_client' (Mid: 2716, RC:0)
Received PUBACK from my_client' (Mid: 2717, RC:0)
Received PUBACK from my_client' (Mid: 2718, RC:0)
Received PUBACK from my_client' (Mid: 2719, RC:0)
Received PUBACK from my_client' (Mid: 2720, RC:0)
Received PUBACK from my_client' (Mid: 2721, RC:0)
Received PUBACK from my_client' (Mid: 2722, RC:0)
Received PUBACK from my_client' (Mid: 2723, RC:0)
Received PUBACK from my_client' (Mid: 2724, RC:0)
Received PUBACK from my_client' (Mid: 2725, RC:0)
Received PUBACK from my_client' (Mid: 2726, RC:0)
Received PUBACK from my_client' (Mid: 2727, RC:0)
Received PUBACK from my_client' (Mid: 2728, RC:0)
Received PUBACK from my_client' (Mid: 2729, RC:0)
Received PUBACK from my_client' (Mid: 2730, RC:0)
Received PUBACK from my_client' (Mid: 2731, RC:0)




Re: Broker not sending all retained messages [message #1856387 is a reply to message #1856379] Thu, 08 December 2022 09:59 Go to previous messageGo to next message
Roger Light is currently offline Roger LightFriend
Messages: 90
Registered: September 2013
Member
Hi Garrett,

Thanks for the detailed information, it's much appreciated.

The default value for max_queued_messages is 100 on 1.6, so you end up with 100 queued plus the default 20 inflight to get 120 messages total.

I have tested locally on 1.6.9, setting max_queued_messages to 250 and I received all 200 messages, so I can't say what happened in your test like that. I would suggest revisiting it to make doubly sure the right config file was being loaded, for example.

The public server at test.mosquitto.org also works as you would hope.

Regards,

Roger
Re: Broker not sending all retained messages [message #1856415 is a reply to message #1856387] Thu, 08 December 2022 20:33 Go to previous message
Garrett Brennan is currently offline Garrett BrennanFriend
Messages: 4
Registered: December 2022
Junior Member
Hi Roger

Thanks for the reply.
I have upgraded top the latest Mosquitto (2.0.15), and will re-test with that.
However, I am having connection issues now, so I will get back to you on how I get on with the retained messages later thanks :)
Garrett
Previous Topic:Bridge Device to Broker on same machine?
Next Topic:Connecting to broker with username and password using mqtt.js
Goto Forum:
  


Current Time: Thu Apr 25 04:19:08 GMT 2024

Powered by FUDForum. Page generated in 0.03057 seconds
.:: Contact :: Home ::.

Powered by: FUDforum 3.0.2.
Copyright ©2001-2010 FUDforum Bulletin Board Software

Back to the top