clean up

CDCgov · Feb 5, 2024 · 42ed95a · 42ed95a
1 parent 65833bc
commit 42ed95a
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/data-ingestion-service/src/main/java/gov/cdc/dataingestion/constant/KafkaHeaderValue.java b/data-ingestion-service/src/main/java/gov/cdc/dataingestion/constant/KafkaHeaderValue.java
@@ -14,6 +14,4 @@ private KafkaHeaderValue() {
     public static final String MESSAGE_VERSION = "MESSAGE_VERSION";
 
     public static final String MESSAGE_OPERATION = "MESSAGE_OPERATION";
-
-    public static final String INGESTION_MODE = "INGESTION_MODE";
 }
diff --git a/...e/src/main/java/gov/cdc/dataingestion/kafka/integration/service/KafkaConsumerService.java b/...e/src/main/java/gov/cdc/dataingestion/kafka/integration/service/KafkaConsumerService.java
@@ -3,7 +3,6 @@
 
 import ca.uhn.hl7v2.HL7Exception;
 import com.google.gson.Gson;
-import gov.cdc.dataingestion.constant.IngestionMode;
 import gov.cdc.dataingestion.constant.enums.EnumKafkaOperation;
 import gov.cdc.dataingestion.conversion.integration.interfaces.IHL7ToFHIRConversion;
 import gov.cdc.dataingestion.conversion.repository.IHL7ToFHIRRepository;
@@ -526,7 +525,6 @@ private void validationHandler(String message, boolean hl7ValidationActivated) t
                 // Duplication check
                 iHL7DuplicateValidator.validateHL7Document(hl7ValidatedModel);
                 saveValidatedELRMessage(hl7ValidatedModel);
-
                 kafkaProducerService.sendMessageAfterValidatingMessage(hl7ValidatedModel, validatedTopic, 0);
                 break;
             case KafkaHeaderValue.MESSAGE_TYPE_CSV: