diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java index a4ea7a6dba..3b83ee0398 100644 --- a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java @@ -1202,6 +1202,7 @@ public class MessageDatabase extends ServiceSupport implements BrokerServiceAwar } // check we are not deleting file with ack for in-use journal files + LOG.debug("gc candidates: " + gcCandidateSet); final TreeSet gcCandidates = new TreeSet(gcCandidateSet); Iterator candidates = gcCandidateSet.iterator(); while (candidates.hasNext()) {