From 9bf9eb01fe991912db7cd16efcf79dbd9e73ec57 Mon Sep 17 00:00:00 2001 From: EvanAdam Date: Wed, 24 Sep 2025 10:47:35 +0200 Subject: [PATCH] enh(flush): reduce log when broker don't have messages --- modules/centreon-stream-connectors-lib/sc_flush.lua | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/modules/centreon-stream-connectors-lib/sc_flush.lua b/modules/centreon-stream-connectors-lib/sc_flush.lua index 71ab72d3..431199b8 100644 --- a/modules/centreon-stream-connectors-lib/sc_flush.lua +++ b/modules/centreon-stream-connectors-lib/sc_flush.lua @@ -114,9 +114,11 @@ function ScFlush:get_queues_size() for _, element_info in pairs(self.params.accepted_elements_info) do queues_size = queues_size + #self.queues[element_info.category_id][element_info.element_id].events - self.sc_logger:debug("[sc_flush:get_queues_size]: size of queue for category " .. tostring(element_info.category_name) - .. " and element: " .. tostring(element_info.element_name) - .. " is: " .. tostring(#self.queues[element_info.category_id][element_info.element_id].events)) + if #self.queues[element_info.category_id][element_info.element_id].events > 0 then + self.sc_logger:debug("[sc_flush:get_queues_size]: size of queue for category " .. tostring(element_info.category_name) + .. " and element: " .. tostring(element_info.element_name) + .. " is: " .. tostring(#self.queues[element_info.category_id][element_info.element_id].events)) + end end return queues_size