diff --git a/htroot/News.java b/htroot/News.java index d9486e300..dd118fdae 100644 --- a/htroot/News.java +++ b/htroot/News.java @@ -95,14 +95,14 @@ public class News { } yacyNewsRecord record; try { -// if ((tableID == yacyNewsPool.PROCESSED_DB) || (tableID == yacyNewsPool.PUBLISHED_DB)) { -// yacyCore.newsPool.clear(tableID); -// } else { + if ((tableID == yacyNewsPool.PROCESSED_DB) || (tableID == yacyNewsPool.PUBLISHED_DB)) { + yacyCore.newsPool.clear(tableID); + } else { while (yacyCore.newsPool.size(tableID) > 0) { record = yacyCore.newsPool.get(tableID, 0); yacyCore.newsPool.moveOff(tableID, record.id()); } -// } + } } catch (IOException e) { e.printStackTrace(); } diff --git a/source/de/anomic/yacy/yacyNewsPool.java b/source/de/anomic/yacy/yacyNewsPool.java index 13b49c933..bbbcc6f76 100644 --- a/source/de/anomic/yacy/yacyNewsPool.java +++ b/source/de/anomic/yacy/yacyNewsPool.java @@ -460,8 +460,7 @@ public class yacyNewsPool { } public void clear(int dbKey) { - // this is called if a queue element shall be moved to another queue or off the queue - // it depends on the dbKey how the record is handled + // clear a table switch (dbKey) { case INCOMING_DB: incomingNews.clear(); break; case PROCESSED_DB: processedNews.clear(); break;