removed transformer to orchestrator flow

samagra-comms · Apr 18, 2022 · cc0b7a5 · cc0b7a5
1 parent 3f9e60b
commit cc0b7a5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git 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
@@ -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