scottk/wlan-cloud-ucentralgw
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw.git synced 2025-11-02 19:57:49 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Adding Kafka telemetry

Browse Source
This commit is contained in:
stephb9959
2022-01-09 21:21:29 -08:00
parent 7889017579
commit 4ebd8b451b
3 changed files with 9 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/RESTAPI/RESTAPI_device_commandHandler.cpp
View File

@@ -842,7 +842,7 @@ void RESTAPI_device_commandHandler::MakeRequest() {
std::stringstream oooss;
Obj->stringify(oooss);
std::cout << "Payload:" << oooss.str() << std::endl;
// std::cout << "Payload:" << oooss.str() << std::endl;
uint64_t Lifetime = 60 * 60 ; // 1 hour
uint64_t Interval = 5;
@@ -855,7 +855,7 @@ void RESTAPI_device_commandHandler::MakeRequest() {
AssignIfPresent(Obj, RESTAPI::Protocol::INTERVAL, Interval);
AssignIfPresent(Obj, RESTAPI::Protocol::LIFETIME, Lifetime);
std::cout << "I:" << Interval << " L:" << Lifetime << std::endl;
// std::cout << "I:" << Interval << " L:" << Lifetime << std::endl;
auto DeviceConnection = DeviceRegistry()->GetDeviceConnection(SerialNumber_);
if(DeviceConnection->WSConn_== nullptr) {
@@ -908,10 +908,9 @@ void RESTAPI_device_commandHandler::MakeRequest() {
TelemetryStatus.set("kafkaClients", TelemetryKafkaCount);
Answer.set("status", TelemetryStatus);
std::ostringstream ooss;
Answer.stringify(ooss);
std::cout << "Telemetry status: " << ooss.str() << std::endl;
// std::ostringstream ooss;
// Answer.stringify(ooss);
// std::cout << "Telemetry status: " << ooss.str() << std::endl;
return ReturnObject(Answer);
}