[activemq] branch main updated: [AMQ-9258] Add NPE guards to kahadb test that intermittently fails on slower CI servers (#1006)

[mattrpav]

This is an automated email from the ASF dual-hosted git repository.

mattrpav pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/main by this push:
     new 0a042964c8 [AMQ-9258] Add NPE guards to kahadb test that 
intermittently fails on slower CI servers (#1006)
0a042964c8 is described below

commit 0a042964c8e0d8c5f694728ded6d278810756bc7
Author: Matt Pavlovich <m...@hyte.io>
AuthorDate: Wed May 17 10:27:31 2023 -0500

    [AMQ-9258] Add NPE guards to kahadb test that intermittently fails on 
slower CI servers (#1006)
---
 .../store/kahadb/JournalCorruptionEofIndexRecoveryTest.java        | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/activemq-kahadb-store/src/test/java/org/apache/activemq/store/kahadb/JournalCorruptionEofIndexRecoveryTest.java
 
b/activemq-kahadb-store/src/test/java/org/apache/activemq/store/kahadb/JournalCorruptionEofIndexRecoveryTest.java
index 0033e0b2c7..da89e5fd83 100644
--- 
a/activemq-kahadb-store/src/test/java/org/apache/activemq/store/kahadb/JournalCorruptionEofIndexRecoveryTest.java
+++ 
b/activemq-kahadb-store/src/test/java/org/apache/activemq/store/kahadb/JournalCorruptionEofIndexRecoveryTest.java
@@ -239,8 +239,13 @@ public class JournalCorruptionEofIndexRecoveryTest {
         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);
                 }