scottk/wlan-cloud-ucentralsec
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git synced 2025-10-30 02:12:32 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Framework update.

Browse Source 
Signed-off-by: jaspreetsachdev <jaspreetsachdev@fb.com>
This commit is contained in:
stephb9959
2022-05-19 00:42:24 -07:00
committed by jaspreetsachdev
parent 46fdf66141
commit 3be0fd45d9
3 changed files with 43 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/framework/MicroService.h
View File

@@ -4148,10 +4148,10 @@ namespace OpenWifi {
Producer.produce(
cppkafka::MessageBuilder(Msg->Topic()).key(Msg->Key()).payload(Msg->Payload()));
}
} catch (const cppkafka::HandleException &E) {
KafkaManager()->Logger().warning(fmt::format("Caught a Kafka exception (producer): {}", E.what()));
} catch( const Poco::Exception &E) {
KafkaManager()->Logger().log(E);
} catch (const cppkafka::HandleException &E) {
KafkaManager()->Logger().error(fmt::format("{}: Exception --> {}", E.get_error().to_string(), E.what()));
} catch (...) {
KafkaManager()->Logger().error("std::exception");
}
@@ -4212,7 +4212,8 @@ namespace OpenWifi {
if (Msg.get_error()) {
if (!Msg.is_eof()) {
KafkaManager()->Logger().error(fmt::format("Error: {}", Msg.get_error().to_string()));
}if(!AutoCommit)
}
if(!AutoCommit)
Consumer.async_commit(Msg);
continue;
}