scottk/wlan-cloud-ucentralgw
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw.git synced 2025-11-03 12:17:56 +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:23:35 -08:00
parent 4ebd8b451b
commit de028b8dc0
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/RESTAPI/RESTAPI_device_commandHandler.cpp
View File

@@ -862,12 +862,15 @@ void RESTAPI_device_commandHandler::MakeRequest() {
return BadRequest(RESTAPI::Errors::DeviceNotConnected);
}
auto NewUUID = MicroService::instance().CreateUUID();
Poco::JSON::Object Answer;
if(KafkaOnly) {
if (Interval) {
DeviceConnection->WSConn_->SetKafkaTelemetryReporting(Interval, Lifetime);
Answer.set("action", "Kafka telemetry started.");
Answer.set("uuid", NewUUID);
} else {
DeviceConnection->WSConn_->StopKafkaTelemetry();
Answer.set("action", "Kafka telemetry stopped.");
@@ -876,7 +879,6 @@ void RESTAPI_device_commandHandler::MakeRequest() {
if (Interval) {
DeviceConnection->WSConn_->SetWebSocketTelemetryReporting(Interval, Lifetime);
std::string EndPoint;
auto NewUUID = MicroService::instance().CreateUUID();
if (TelemetryStream()->CreateEndpoint(SerialNumber_, EndPoint, NewUUID)) {
Answer.set("action", "WebSocket telemetry started.");
Answer.set("serialNumber", SerialNumber_);