Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

no jira - additional trace logging to kahadb cleanup/gc to identify datafile for durable sub command and pending count by sub key

This commit is contained in:
gtully 2020-02-28 09:47:02 +00:00
parent 46148e3dd1
commit 5d03224880
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -1923,7 +1923,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
(pendingAcks.size() == 1 && pendingAcks.getTail().range() == 1)) { (pendingAcks.size() == 1 && pendingAcks.getTail().range() == 1)) {
if (LOG.isTraceEnabled()) { if (LOG.isTraceEnabled()) {
LOG.trace("Found candidate for rewrite: {} from file {}", entry.getKey(), dataFileId); LOG.trace("Found candidate for rewrite: sub {} on {} from file {}", subscriptionKey, entry.getKey(), dataFileId);
} }
final KahaSubscriptionCommand kahaSub = final KahaSubscriptionCommand kahaSub =
@ -1939,6 +1939,12 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
} }
} }
if (LOG.isTraceEnabled()) {
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);
}
gcCandidateSet.remove(dataFileId); gcCandidateSet.remove(dataFileId);
} }
} }