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

Signed-off-by: stephb9959 <[email protected]>
Telecominfraproject · Oct 26, 2023 · d7bad29 · d7bad29
1 parent 06766d2
commit d7bad29
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/src/AP_WS_Connection.cpp b/src/AP_WS_Connection.cpp
@@ -501,7 +501,6 @@ namespace OpenWifi {
 		} break;
 
 		case uCentralProtocol::Events::ET_EVENT: {
-			ParamsObj->stringify(std::cout);
 			Process_event(ParamsObj);
 		} break;
 

diff --git a/src/AP_WS_Process_event.cpp b/src/AP_WS_Process_event.cpp
@@ -34,8 +34,14 @@ namespace OpenWifi {
 					FullEvent.set("type", EventType);
 					FullEvent.set("timestamp", EventTimeStamp);
 					FullEvent.set("payload", EventPayload);
-					KafkaManager()->PostMessage(KafkaTopics::DEVICE_EVENT_QUEUE, SerialNumber_,
-												FullEvent);
+					if(strncmp(EventType.c_str(),"rrm.",4) == 0 ) {
+						std::cout << "Publishing " << EventType << " to RRM" << std::endl;
+						KafkaManager()->PostMessage(KafkaTopics::RRM, SerialNumber_,
+													FullEvent);
+					} else {
+						KafkaManager()->PostMessage(KafkaTopics::DEVICE_EVENT_QUEUE, SerialNumber_,
+													FullEvent);
+					}
 				}
 			}
 		} catch (const Poco::Exception &E) {

diff --git a/src/framework/KafkaTopics.h b/src/framework/KafkaTopics.h
@@ -20,6 +20,7 @@ namespace OpenWifi::KafkaTopics {
 	inline const char * DEVICE_EVENT_QUEUE = "device_event_queue";
 	inline const char * DEVICE_TELEMETRY = "device_telemetry";
 	inline const char * PROVISIONING_CHANGE = "provisioning_change";
+	inline const char * RRM = "rrm";
 
 	namespace ServiceEvents {
 		inline const char * EVENT_JOIN = "join";