scottk/wlan-cloud-owprov
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-owprov.git synced 2025-10-29 09:42:38 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

https://telecominfraproject.atlassian.net/browse/WIFI-11303

Browse Source 
Signed-off-by: stephb9959 <stephane.bourque@gmail.com>
This commit is contained in:
stephb9959
2022-10-30 09:47:13 -07:00
parent 4f4dcc9071
commit 8b23197359
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/framework/KafkaManager.cpp
View File

@@ -307,15 +307,9 @@ namespace OpenWifi {
std::cout << __LINE__ << std::endl;
poco_information(Logger(),"Starting...");
std::cout << __LINE__ << std::endl;
ConsumerThr_ = std::make_unique<KafkaConsumer>(Logger().create("KAFKA-CONSUMER",Logger().getChannel()));
std::cout << __LINE__ << std::endl;
ConsumerThr_->Start();
std::cout << __LINE__ << std::endl;
ProducerThr_ = std::make_unique<KafkaProducer>(Logger().create("KAFKA-PRODUCER",Logger().getChannel()));
std::cout << __LINE__ << std::endl;
ProducerThr_->Start();
std::cout << __LINE__ << std::endl;
Dispatcher_ = std::make_unique<KafkaDispatcher>(Logger().create("KAFKA-DISPATCHER",Logger().getChannel()));
std::cout << __LINE__ << std::endl;
Dispatcher_->Start();
std::cout << __LINE__ << std::endl;

8
src/framework/KafkaManager.h
View File

@@ -126,6 +126,14 @@ namespace OpenWifi {
KafkaManager() noexcept:
SubSystemServer("KafkaManager", "KAFKA-SVR", "openwifi.kafka") {
ConsumerThr_ = std::make_unique<KafkaConsumer>(Logger().create("KAFKA-CONSUMER",Logger().getChannel()));
std::cout << __LINE__ << std::endl;
std::cout << __LINE__ << std::endl;
ProducerThr_ = std::make_unique<KafkaProducer>(Logger().create("KAFKA-PRODUCER",Logger().getChannel()));
std::cout << __LINE__ << std::endl;
std::cout << __LINE__ << std::endl;
Dispatcher_ = std::make_unique<KafkaDispatcher>(Logger().create("KAFKA-DISPATCHER",Logger().getChannel()));
std::cout << __LINE__ << std::endl;
}
};