From 8e5fd817640eab1fa605c87c5880e892d1fc8a04 Mon Sep 17 00:00:00 2001 From: "Roger A. Light" Date: Mon, 16 Dec 2024 22:53:25 +0000 Subject: [PATCH] Fix sys tree message expiry --- src/sys_tree.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/sys_tree.c b/src/sys_tree.c index ff0c0450..f94cba0a 100644 --- a/src/sys_tree.c +++ b/src/sys_tree.c @@ -220,7 +220,7 @@ void sys_tree__update(bool force) uptime = db.now_s - start_time; len = (uint32_t)snprintf(buf, BUFLEN, "%" PRIu64 " seconds", (uint64_t)uptime); - db__messages_easy_queue(NULL, "$SYS/broker/uptime", SYS_TREE_QOS, len, buf, 1, 0, NULL); + db__messages_easy_queue(NULL, "$SYS/broker/uptime", SYS_TREE_QOS, len, buf, 1, MSG_EXPIRY_INFINITE, NULL); /* Update metrics values where not otherwise updated */ metrics[mosq_gauge_message_store_count].next = db.msg_store_count; @@ -263,10 +263,10 @@ void sys_tree__update(bool force) metrics[i].current = metrics[i].next; len = (uint32_t)snprintf(buf, BUFLEN, "%lu", metrics[i].current); if(metrics[i].topic){ - db__messages_easy_queue(NULL, metrics[i].topic, SYS_TREE_QOS, len, buf, 1, 0, NULL); + db__messages_easy_queue(NULL, metrics[i].topic, SYS_TREE_QOS, len, buf, 1, MSG_EXPIRY_INFINITE, NULL); } if(metrics[i].topic_alias){ - db__messages_easy_queue(NULL, metrics[i].topic_alias, SYS_TREE_QOS, len, buf, 1, 0, NULL); + db__messages_easy_queue(NULL, metrics[i].topic_alias, SYS_TREE_QOS, len, buf, 1, MSG_EXPIRY_INFINITE, NULL); } } }