Start logging programatically as log4j not started in time

framework-tools-replay/pom.xml

@@ -14,6 +14,10 @@
 
     <modelVersion>4.0.0</modelVersion>
 
+    <properties>
+        <log4j-core.version>2.5</log4j-core.version>
+    </properties>
+
     <dependencyManagement>
         <dependencies>
             <dependency>
@@ -107,6 +111,11 @@
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-log4j12</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j-core.version}</version>
+        </dependency>
         <dependency>
             <groupId>javax</groupId>
             <artifactId>javaee-api</artifactId>

framework-tools-replay/src/main/java/uk/gov/justice/framework/tools/replay/LoggerConfigurator.java

@@ -0,0 +1,21 @@
+package uk.gov.justice.framework.tools.replay;
+
+import static org.apache.log4j.Level.DEBUG;
+import static org.apache.log4j.Level.INFO;
+import static org.apache.log4j.Level.WARN;
+
+import org.apache.log4j.Logger;
+import org.apache.log4j.spi.LoggerRepository;
+
+public class LoggerConfigurator {
+
+    public void startLoggingProgramaticallyAsLog4JNotYetStarted() {
+        final Logger rootLogger = Logger.getRootLogger();
+        rootLogger.setLevel(INFO);
+        final LoggerRepository loggerRepository = rootLogger.getLoggerRepository();
+
+        loggerRepository.getLogger("uk.gov.justice").setLevel(DEBUG);
+        loggerRepository.getLogger("org.hibernate").setLevel(WARN);
+        loggerRepository.getLogger("org.apache.deltaspike").setLevel(WARN);
+    }
+}

framework-tools-replay/src/main/java/uk/gov/justice/framework/tools/replay/StartReplay.java

@@ -43,12 +43,18 @@ public class StartReplay implements ManagedTaskListener {
     @Inject
     private AsyncStreamDispatcher asyncStreamDispatcher;
 
+    @Inject
+    private LoggerConfigurator loggerConfigurator;
+
     private Deque<Future<UUID>> outstandingTasks = new LinkedBlockingDeque<>();
 
     private boolean allTasksCreated = false;
 
     @PostConstruct
     void go() {
+
+        loggerConfigurator.startLoggingProgramaticallyAsLog4JNotYetStarted();
+
         logger.info("-------------- Invoke Event Streams Replay-------------!");
         checkForMainProcessFile();
 
@@ -64,6 +70,8 @@ void go() {
 
     }
 
+
+
     @Override
     public void taskAborted(final Future<?> dispatchTaskFuture, final ManagedExecutorService managedExecutorService, final Object dispatchTask, final Throwable throwable) {
         logger.debug("Dispatch task aborted");

framework-tools-replay/src/main/resources/log4j.properties

@@ -1,5 +1,5 @@
 # Set root logger level to DEBUG and its only appender to A1.
-log4j.rootLogger=INFO, A1 file
+log4j.rootLogger=DEBUG, A1
 # A1 is set to be a ConsoleAppender.
 log4j.appender.A1=org.apache.log4j.ConsoleAppender
 # A1 uses PatternLayout.

framework-tools-replay/src/test/java/uk/gov/justice/framework/tools/replay/StartReplayTest.java

@@ -52,6 +52,9 @@ public class StartReplayTest {
     @Mock
     private Logger logger;
 
+    @Mock
+    private LoggerConfigurator loggerConfigurator;
+
     @InjectMocks
     private StartReplay startReplay;
 
@@ -66,6 +69,7 @@ public void shouldDispatchStreams() throws IOException {
 
         startReplay.go();
 
+        verify(loggerConfigurator).startLoggingProgramaticallyAsLog4JNotYetStarted();
         verify(executorService, times(2)).submit(any(StreamDispatchTask.class));
         verify(logger).info("-------------- Invoke Event Streams Replay-------------!");
     }

replay-tool-test/replay-tool-it-example-listener/src/main/java/uk/gov/justice/framework/tools/listener/FrameworkToolsTestListener.java

@@ -30,13 +30,13 @@ public class FrameworkToolsTestListener {
 
     @Handles("framework.update-user")
     public void handle(final JsonEnvelope envelope) {
-        logger.info("Replaying event: " + envelope);
+
+        logger.debug("Replaying event: " + envelope);
         testViewstoreRepository.save(fromJsonEnvelope(envelope));
     }
 
     private User fromJsonEnvelope(final JsonEnvelope envelope) {
 
-
         final String payload = envelope.payloadAsJsonObject().toString();
 
         try {