Skip to content

Commit e776a3a

Browse files
committed
Added debug messages about queue purge
1 parent 10e7fb2 commit e776a3a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

broker/src/main/java/io/moquette/broker/unsafequeues/QueuePool.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -389,9 +389,10 @@ void purgeQueue(String name) {
389389
final LinkedList<SegmentRef> segmentRefs = queueSegments.remove(queueName);
390390
SegmentRef segmentRef = segmentRefs.pollLast();
391391
segmentsAllocationLock.lock();
392+
LOG.debug("Purging segments for queue {}", queueName);
392393
try {
393394
while (segmentRef != null) {
394-
LOG.debug("Consumed tail segment {} from queue {}", segmentRef, queueName);
395+
LOG.debug("Purging segment {} from queue {}", segmentRef, queueName);
395396
recycledSegments.add(segmentRef);
396397
segmentRef = segmentRefs.pollLast();
397398
}

0 commit comments

Comments
 (0)