[AMQ-9258] Add NPE guards to kahadb test that intermittently fails on…

… slower CI servers (apache#1006)
amazon-mq · Sep 1, 2023 · df07079 · df07079
1 parent 14e339c
commit df07079
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...src/test/java/org/apache/activemq/store/kahadb/JournalCorruptionEofIndexRecoveryTest.java b/...src/test/java/org/apache/activemq/store/kahadb/JournalCorruptionEofIndexRecoveryTest.java
@@ -239,8 +239,13 @@ public void testRecoveryAfterCorruptionMetadataLocation() throws Exception {
         final var appender = new AbstractAppender("testAppender", new AbstractFilter() {}, new MessageLayout(), false, new Property[0]) {
             @Override
             public void append(LogEvent event) {
-                if (event.getLevel() == Level.WARN
+                if (event != null 
+                        && event.getLevel() == Level.WARN
+                        && event.getMessage() != null
+                        && event.getMessage().getFormattedMessage() != null
                         && event.getMessage().getFormattedMessage().contains("Cannot recover message audit")
+                        && event.getThrown() != null
+                        && event.getThrown().getLocalizedMessage() != null
                         && event.getThrown().getLocalizedMessage().contains("Invalid location size")) {
                     trappedExpectedLogMessage.set(true);
                 }