diff --git a/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java b/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java index 7b50727a..2757f7bf 100644 --- a/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java +++ b/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java @@ -1075,8 +1075,12 @@ implements Closeable, if (queuePat.matcher(qname).matches()) { WorkQueue wq = getQueueFor(qname); wq.unpeek(null); - count += wq.deleteMatching(this, uriRegex); + long delCount = wq.deleteMatching(this, uriRegex); + if (!wq.isRetired()) { + count += delCount; + } wq.makeDirty(); + } } decrementQueuedCount(count);