You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2025/10/07 14:33:23 UTC
(activemq) branch main updated: [AMQ-9780] Add a null guard during checkpointUpdate when kahadb is logging in TRACE mode (#1506)
This is an automated email from the ASF dual-hosted git repository.
jbonofre 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 56c8784c0b [AMQ-9780] Add a null guard during checkpointUpdate when kahadb is logging in TRACE mode (#1506)
56c8784c0b is described below
commit 56c8784c0b949acb1bf860568baab6533a7c8dab
Author: Matt Pavlovich <ma...@apache.org>
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 088d9f297d..85ff18fc80 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: commits-unsubscribe@activemq.apache.org
For additional commands, e-mail: commits-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact