Telecominfraproject/archived-wlan-cloud-ucentralgw
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw.git synced 2026-03-20 03:41:02 +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:12:26 -08:00
parent 268c542602
commit 7fb9c8c675
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/RESTAPI/RESTAPI_device_commandHandler.cpp
View File

@@ -873,8 +873,8 @@ void RESTAPI_device_commandHandler::MakeRequest() {
Answer.set("action", "Kafka telemetry stopped.");
}
} else {
DeviceConnection->WSConn_->SetWebSocketTelemetryReporting(Interval, Lifetime);
if (Interval) {
DeviceConnection->WSConn_->SetWebSocketTelemetryReporting(Interval, Lifetime);
std::string EndPoint;
auto NewUUID = MicroService::instance().CreateUUID();
if (TelemetryStream()->CreateEndpoint(SerialNumber_, EndPoint, NewUUID)) {
@@ -885,9 +885,10 @@ void RESTAPI_device_commandHandler::MakeRequest() {
} else {
return BadRequest(RESTAPI::Errors::InternalError);
}
} else {
Answer.set("action", "WebSocket telemetry stopped.");
DeviceConnection->WSConn_->StopWebSocketTelemetry();
}
Answer.set("action", "WebSocket telemetry stopped.");
DeviceConnection->WSConn_->StopWebSocketTelemetry();
}
bool TelemetryRunning;