From 002b0618cf813d48bbff2d287e16f607a4c73d73 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer
Date: Thu, 10 Aug 2023 13:35:35 +0200
Subject: Add tests for KafkaMtbFileSender

---
 src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src/main/kotlin')

diff --git a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
index 9448e29..e7f9769 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
@@ -50,7 +50,7 @@ class KafkaMtbFileSender(
             }
         } catch (e: Exception) {
             logger.error("An error occurred sending to kafka", e)
-            MtbFileSender.Response(RequestStatus.UNKNOWN)
+            MtbFileSender.Response(RequestStatus.ERROR)
         }
     }
 
@@ -79,7 +79,7 @@ class KafkaMtbFileSender(
             }
         } catch (e: Exception) {
             logger.error("An error occurred sending to kafka", e)
-            MtbFileSender.Response(RequestStatus.UNKNOWN)
+            MtbFileSender.Response(RequestStatus.ERROR)
         }
     }
 
-- 
cgit v1.2.3