Merge pull request #214 from raynigon/bugfix/access-logs

Bugfix/access logs

build.gradle

@@ -8,7 +8,7 @@ plugins {
     id 'java-library'
     id 'signing'
     id 'maven-publish'
-    id 'org.springframework.boot' version '3.0.4'
+    id 'org.springframework.boot' version '3.0.6'
     id 'io.spring.dependency-management' version '1.1.0'
 
     // Auto Update Versions

ecs-logging-access/src/main/java/com/raynigon/ecs/logging/access/logback/AccessLogContext.java

@@ -13,13 +13,16 @@
 import com.raynigon.ecs.logging.access.AccessLogProperties;
 import com.raynigon.ecs.logging.access.context.IAccessLogContext;
 import com.raynigon.ecs.logging.access.event.EcsAccessEvent;
+import lombok.extern.slf4j.Slf4j;
 
 import java.net.URL;
 import java.util.*;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
+import java.util.logging.Logger;
 
+@Slf4j
 public class AccessLogContext implements IAccessLogContext, LifeCycle, Context, AppenderAttachable<IAccessEvent> {
 
     private final AccessLogProperties config;
@@ -31,6 +34,7 @@ public class AccessLogContext implements IAccessLogContext, LifeCycle, Context,
     private final Map<String, Object> objects;
     private final URL configLocation;
     private final AppenderAttachableImpl<IAccessEvent> appenderContainer;
+    private final List<ConfigurationEventListener> eventListeners = new ArrayList<>();
     private SequenceNumberGenerator sequenceNumberGenerator;
 
     private ExecutorService executorService;
@@ -71,14 +75,14 @@ public final void appendEvent(EcsAccessEvent event) {
     }
 
     public void start() {
-        executorService = ExecutorServiceUtil.newExecutorService();
+        executorService = ExecutorServiceUtil.newThreadPoolExecutor();
 
         try {
             JoranConfigurator jc = new JoranConfigurator();
             jc.setContext(this);
             jc.doConfigure(this.configLocation);
         } catch (Throwable e) {
-            //TODO handle exception
+            log.error("Unable to start access log", e);
         }
 
         StatusPrinter.printInCaseOfErrorsOrWarnings(this);
@@ -163,6 +167,16 @@ public void setSequenceNumberGenerator(SequenceNumberGenerator sequenceNumberGen
         this.sequenceNumberGenerator = sequenceNumberGenerator;
     }
 
+    @Override
+    public void addConfigurationEventListener(ConfigurationEventListener listener) {
+        eventListeners.add(listener);
+    }
+
+    @Override
+    public void fireConfigurationEvent(ConfigurationEvent configurationEvent) {
+        eventListeners.forEach((listener) -> listener.listen(configurationEvent));
+    }
+
     public ScheduledExecutorService getScheduledExecutorService() {
         throw new UnsupportedOperationException();
     }

gradle.properties

@@ -1,2 +1,2 @@
-version=2.0.1-SNAPSHOT
+version=2.1.0-SNAPSHOT
 org.gradle.caching=true