This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch activemq-6.1.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/activemq-6.1.x by this push:
new 3858d3047e [AMQ-9780] Add a null guard during checkpointUpdate when
kahadb is logging in TRACE mode (#1506)
3858d3047e is described below
commit 3858d3047ef5b2e03e9cc3c834ee0ec17c1ae0f3
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 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: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
