We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7c092d2 commit 0c8e934Copy full SHA for 0c8e934
broker/src/main/java/io/moquette/broker/unsafequeues/QueuePool.java
@@ -389,9 +389,10 @@ void purgeQueue(String name) {
389
final LinkedList<SegmentRef> segmentRefs = queueSegments.remove(queueName);
390
SegmentRef segmentRef = segmentRefs.pollLast();
391
segmentsAllocationLock.lock();
392
+ LOG.debug("Purging segments for queue {}", queueName);
393
try {
394
while (segmentRef != null) {
- LOG.debug("Consumed tail segment {} from queue {}", segmentRef, queueName);
395
+ LOG.debug("Purging segment {} from queue {}", segmentRef, queueName);
396
recycledSegments.add(segmentRef);
397
segmentRef = segmentRefs.pollLast();
398
}
0 commit comments