diff --git a/src/main/java/com/commafeed/backend/FixedSizeSortedSet.java b/src/main/java/com/commafeed/backend/FixedSizeSortedSet.java index a23362dc..a634288c 100644 --- a/src/main/java/com/commafeed/backend/FixedSizeSortedSet.java +++ b/src/main/java/com/commafeed/backend/FixedSizeSortedSet.java @@ -12,11 +12,11 @@ public class FixedSizeSortedSet extends PriorityQueue { private static final long serialVersionUID = 1L; private final Comparator comparator; - private final int maxSize; + private final int capacity; - public FixedSizeSortedSet(int maxSize, Comparator comparator) { - super(maxSize, comparator); - this.maxSize = maxSize; + public FixedSizeSortedSet(int capacity, Comparator comparator) { + super(Math.max(1, capacity), comparator); + this.capacity = capacity < 0 ? Integer.MAX_VALUE : capacity; this.comparator = comparator; } @@ -41,7 +41,7 @@ public class FixedSizeSortedSet extends PriorityQueue { } public boolean isFull() { - return size() == maxSize; + return size() == capacity; } @SuppressWarnings("unchecked") diff --git a/src/main/java/com/commafeed/backend/dao/FeedEntryStatusDAO.java b/src/main/java/com/commafeed/backend/dao/FeedEntryStatusDAO.java index fd358bc7..0d67b6eb 100644 --- a/src/main/java/com/commafeed/backend/dao/FeedEntryStatusDAO.java +++ b/src/main/java/com/commafeed/backend/dao/FeedEntryStatusDAO.java @@ -219,7 +219,7 @@ public class FeedEntryStatusDAO extends GenericDAO { Comparator comparator = order == ReadingOrder.desc ? STATUS_COMPARATOR_DESC : STATUS_COMPARATOR_ASC; FixedSizeSortedSet set = new FixedSizeSortedSet( - capacity < 0 ? Integer.MAX_VALUE : capacity, comparator); + capacity, comparator); for (FeedSubscription sub : subscriptions) { Date last = (order != null && set.isFull()) ? set.last() .getEntryUpdated() : null;