ITEM-241 : Ajout appender personnalisé

Récupération numéro et type demande et concaténation dans chaque message envoyé dans les logs
abes-esr · Oct 15, 2024 · d1563e1 · d1563e1
1 parent 357e809
commit d1563e1
Show file tree

Hide file tree

Showing 3 changed files with 45 additions and 1 deletion.
diff --git a/batch/src/main/java/fr/abes/item/batch/traitement/LireLigneFichierTasklet.java b/batch/src/main/java/fr/abes/item/batch/traitement/LireLigneFichierTasklet.java
@@ -11,6 +11,7 @@
 import fr.abes.item.core.service.ILigneFichierService;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.logging.log4j.ThreadContext;
 import org.hibernate.exception.ConstraintViolationException;
 import org.hibernate.exception.JDBCConnectionException;
 import org.springframework.batch.core.ExitStatus;
@@ -110,6 +111,8 @@ public ExitStatus afterStep(StepExecution stepExecution) {
             stepExecution.getJobExecution().getExecutionContext().put("lignes", this.lignesFichier);
             stepExecution.getJobExecution().getExecutionContext().put("demandeId", this.demandeId);
             stepExecution.getJobExecution().getExecutionContext().put("typeDemande", this.typeDemande.toString());
+            ThreadContext.put("demandeId", String.valueOf(this.demandeId));
+            ThreadContext.put("typeDemande", this.typeDemande.toString());
         }
         return stepExecution.getExitStatus();
     }

diff --git a/batch/src/main/resources/log4j2.xml b/batch/src/main/resources/log4j2.xml
@@ -7,13 +7,14 @@
             <PatternLayout
                     pattern="%style{%d{ISO8601}}{black} %highlight{%-5level }[%style{%t}{bright,blue}] %style{%C{1.}}{dark,yellow}: %msg%n%throwable" />
         </Console>
+        <ItemLogAppender name="ItemLogAppender" />
     </Appenders>
     <Loggers>
         <Root level="info">
             <AppenderRef ref="Console"/>
         </Root>
         <Logger name="fr.abes.item" level="debug" additivity="false">
-            <AppenderRef ref="Console"/>
+            <AppenderRef ref="ItemLogAppender"/>
         </Logger>
     </Loggers>
 </Configuration>
diff --git a/core/src/main/java/fr/abes/item/core/configuration/ItemLogAppender.java b/core/src/main/java/fr/abes/item/core/configuration/ItemLogAppender.java
@@ -0,0 +1,40 @@
+package fr.abes.item.core.configuration;
+
+import org.apache.logging.log4j.Level;
+import org.apache.logging.log4j.ThreadContext;
+import org.apache.logging.log4j.core.Appender;
+import org.apache.logging.log4j.core.Filter;
+import org.apache.logging.log4j.core.LogEvent;
+import org.apache.logging.log4j.core.appender.AbstractAppender;
+import org.apache.logging.log4j.core.config.plugins.Plugin;
+import org.apache.logging.log4j.core.config.plugins.PluginAttribute;
+import org.apache.logging.log4j.core.config.plugins.PluginElement;
+import org.apache.logging.log4j.core.config.plugins.PluginFactory;
+
+@Plugin(name = "ItemLogAppender", category = "core", elementType = Appender.ELEMENT_TYPE)
+public class ItemLogAppender extends AbstractAppender {
+
+    protected ItemLogAppender(String name, Filter filter) {
+        super(name, filter, null);
+    }
+
+    @Override
+    public void append(LogEvent event) {
+        if (event.getLevel().isMoreSpecificThan(Level.INFO)) {
+            String originalMessage = event.getMessage().getFormattedMessage();
+            String demandeId = ThreadContext.get("demandeId");
+            String typeDemande = ThreadContext.get("typeDemande");
+            if (demandeId != null && typeDemande != null) {
+                System.out.println("DEM_" + typeDemande + "_" + demandeId + " : " + originalMessage);
+            }
+        }
+    }
+
+    // Méthode statique pour créer l'instance de l'appender via le fichier de configuration
+    @PluginFactory
+    public static ItemLogAppender createAppender(
+            @PluginAttribute("name") String name,
+            @PluginElement("Filter") Filter filter) {
+        return new ItemLogAppender(name, filter);
+    }
+}