From bfce834fdf88539df5fb821463068383c0e47ee5 Mon Sep 17 00:00:00 2001
From: EryneKL <97091460+EryneKL@users.noreply.github.com>
Date: Tue, 10 Oct 2023 16:06:13 +0200
Subject: [PATCH] =?UTF-8?q?FIX=20:=20CDE-195-creer-consumer-pour-generer-l?=
 =?UTF-8?q?es-2-fichiers-de-log=20=20=20=20=20=20-=20correction=20d'un=20c?=
 =?UTF-8?q?ontr=C3=B4le=20dysfonctionnel?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/fr/abes/logskbart/kafka/LogsListener.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
index ef4432b..3b2c9b4 100644
--- a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
+++ b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
@@ -79,7 +79,7 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
             //  Inscrit l'entity en BDD
             repository.save(entity);
 
-        } else if (message.value().contains("OK")) {    //  Si la ligne sur le topic bestppn.endoftraitment contient OK
+        } else if (message.value().equals("OK")) {    //  Si la ligne sur le topic bestppn.endoftraitment contient OK
 
             //  Créer un nouveau Path avec le FileName (en remplaçant l'extension par .err)
             Path source = null;
@@ -91,8 +91,7 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
             }
 
             //  Copie le fichier existant vers le répertoire temporaire en ajoutant sa date de création
-            assert source != null;
-            if (Files.exists(source)) {
+            if (source != null && Files.exists(source)) {
                 LocalDateTime time = LocalDateTime.now();
                 DateTimeFormatter format = DateTimeFormatter.ofPattern("yyyy-MM-dd-HH-mm-ss", Locale.FRANCE);
                 String date = format.format(time);