Compare commits

...

3 Commits

Author SHA1 Message Date
Ivan Chvets
1832d2c1cb Merge branch 'main' of github.com:Telecominfraproject/wlan-cloud-owprov into fix_improve_exeception_handling 2025-05-02 10:58:26 -04:00
i-chvets
0ef1dad4dc Merge pull request #117 from Telecominfraproject/fix_ci
fix: Updated CI with ubuntu-latest.
2025-05-02 10:57:21 -04:00
Ivan Chvets
fe6023b18d Exception handling improvement. Details in: https://telecominfraproject.atlassian.net/browse/WIFI-14038
Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
2025-05-01 17:49:04 -04:00

View File

@@ -118,6 +118,10 @@ namespace OpenWifi {
Producer.poll((std::chrono::milliseconds) 0);
}
}
if (Queue_.size() == 0) {
// message queue is empty, flush all previously sent messages
Producer.flush();
}
} catch (const cppkafka::HandleException &E) {
poco_warning(Logger_,
fmt::format("Caught a Kafka exception (producer): {}", E.what()));
@@ -126,10 +130,6 @@ namespace OpenWifi {
} catch (...) {
poco_error(Logger_, "std::exception");
}
if (Queue_.size() == 0) {
// message queue is empty, flush all previously sent messages
Producer.flush();
}
Note = Queue_.waitDequeueNotification();
}
Producer.flush();