From cc0b7a563e479675259c52efa56a1ba52170ce85 Mon Sep 17 00:00:00 2001
From: Surabhi <surabhi.mahawar@aurigait.com>
Date: Mon, 18 Apr 2022 18:21:12 +0530
Subject: [PATCH] removed transformer to orchestrator flow

---
 .../java/com/uci/transformer/odk/ODKConsumerReactive.java  | 7 ++-----
 src/main/resources/application.properties                  | 1 -
 2 files changed, 2 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java b/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java
index de29b29..c08bf21 100644
--- a/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java
+++ b/src/main/java/com/uci/transformer/odk/ODKConsumerReactive.java
@@ -82,9 +82,6 @@ public class ODKConsumerReactive extends TransformerProvider {
     @Value("${outbound}")
     public String outboundTopic;
 
-    @Value("${processOutbound}")
-    private String processOutboundTopic;
-
     @Value("${telemetry}")
     public String telemetryTopic;
 
@@ -144,7 +141,7 @@ public void accept(List<XMessage> messages) {
                                         messages = (ArrayList<XMessage>) messages;
                                         for (XMessage msg : messages) {
                                             try {
-                                                kafkaProducer.send(processOutboundTopic, msg.toXML());
+                                                kafkaProducer.send(outboundTopic, msg.toXML());
                                             } catch (JAXBException e) {
                                                 e.printStackTrace();
                                             }
@@ -159,7 +156,7 @@ public void accept(XMessage transformedMessage) {
                                                 logTimeTaken(startTime, 2);
                                                 if (transformedMessage != null) {
                                                     try {
-                                                        kafkaProducer.send(processOutboundTopic, transformedMessage.toXML());
+                                                        kafkaProducer.send(outboundTopic, transformedMessage.toXML());
                                                         long endTime = System.nanoTime();
                                                         long duration = (endTime - startTime);
                                                         log.error("Total time spent in processing form: " + duration / 1000000);
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index a84db56..8ec30ee 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -16,7 +16,6 @@ gupshup-opted-out=${KAFKA_INBOUND_GS_OPTED_OUT_TOPIC}
 inbound-error=${KAFKA_INBOUND_ERROR_TOPIC}
 odk-transformer=${KAFKA_ODK_TRANSFORMER_TOPIC}
 odk-topic-pattern=${KAFKA_ODK_TRANSFORMER_TOPIC_PATTERN}
-processOutbound=${KAFKA_PROCESS_OUTBOUND}
 
 spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
 spring.r2dbc.initialization-mode=always