This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch activemq-5.19.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/activemq-5.19.x by this push:
new 6e856394dd [AMQ-9780] Add a null guard during checkpointUpdate when
kahadb is logging in TRACE mode (#1506)
6e856394dd is described below
commit 6e856394dd60c98676cf902127e75dab3acce2e2
Author: Matt Pavlovich <[email protected]>
AuthorDate: Tue Oct 7 09:33:18 2025 -0500
[AMQ-9780] Add a null guard during checkpointUpdate when kahadb is logging
in TRACE mode (#1506)
---
.../src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
index c8a9cc9192..33fead2749 100644
---
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
+++
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
@@ -1967,7 +1967,7 @@ public abstract class MessageDatabase extends
ServiceSupport implements BrokerSe
final StoredDestination destination =
entry.getValue();
final String subscriptionKey =
subscription.getKey();
final SequenceSet pendingAcks =
destination.ackPositions.get(tx, subscriptionKey);
- LOG.trace("sub {} on {} in dataFile {} has
pendingCount {}", subscriptionKey, entry.getKey(), dataFileId,
pendingAcks.rangeSize()-1);
+ LOG.trace("sub {} on {} in dataFile {} has
pendingCount {}", subscriptionKey, entry.getKey(), dataFileId, (pendingAcks !=
null ? pendingAcks.rangeSize()-1 : 0));
}
gcCandidateSet.remove(dataFileId);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
