Remove Filtered TMC Topic deposit from Asn1DecodedDataRouter, TimDepo…

…sitController
CDOT-CV · Oct 11, 2024 · aa57462 · aa57462
1 parent 286f170
commit aa57462
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 20 deletions.
diff --git a/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/services/asn1/Asn1DecodedDataRouter.java b/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/services/asn1/Asn1DecodedDataRouter.java
@@ -103,16 +103,6 @@ public Object process(String consumedData) {
 				// Send all TIMs also to OdeTimJson
 				timProducer.send(odeProperties.getKafkaTopicOdeTimJson(), getRecord().key(), odeTimData);
 				logger.debug("Submitted to TIM Pojo topic");
-				// If the TIM was generated by the TMC broadcast to the filtered TMC TIM Kafka topic
-				try {
-					String generatedBy = (new JSONObject(odeTimData)).getJSONObject("metadata")
-							.getString("recordGeneratedBy");
-					if (generatedBy.equalsIgnoreCase("TMC_VIA_SAT") || generatedBy.equalsIgnoreCase("TMC_VIA_SNMP")) {
-						timProducer.send(odeProperties.getKafkaTopicOdeTimJsonTMCFiltered(), null, odeTimData);
-					}
-				} catch (Exception e) {
-					logger.error("Error while checking recordGeneratedBy field: {}", e.getMessage());
-				}
 			} else if (messageId == J2735DSRCmsgID.SPATMessage.getMsgID()) {
 				String odeSpatData = OdeSpatDataCreatorHelper.createOdeSpatData(consumedData).toString();
 				if (recordType == RecordType.dnMsg) {

diff --git a/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/traveler/TimDepositController.java b/jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/traveler/TimDepositController.java
@@ -202,16 +202,6 @@ public synchronized ResponseEntity<String> depositTim(String jsonString, Request
       String obfuscatedTimData = TimTransmogrifier.obfuscateRsuPassword(odeTimData.toJson());
       stringMsgProducer.send(odeProperties.getKafkaTopicOdeTimBroadcastJson(), null, obfuscatedTimData);
 
-      // If the TIM was generated by the TMC broadcast to the filtered TMC TIM Kafka topic
-      try {
-         String generatedBy = (new JSONObject(obfuscatedTimData)).getJSONObject("metadata").getString("recordGeneratedBy");
-         if (generatedBy.equalsIgnoreCase("TMC")) {
-            stringMsgProducer.send(odeProperties.getKafkaTopicOdeTimJsonTMCFiltered(), null, obfuscatedTimData);
-         }
-      } catch (Exception e) {
-         logger.error("Error while checking recordGeneratedBy field: {}", e.getMessage());
-      }
-
       // Now that the message gas been published to OdeBradcastTim topic, it should be
       // changed to J2735BroadcastTim serialId
       timMetadata.setSerialId(serialIdJ2735);