Make exit conditions slightly more conservative.

This commit is contained in:
Jon Chambers
2020-09-23 11:21:16 -04:00
committed by Jon Chambers
parent 599cd766e1
commit 6041a9d094

View File

@@ -92,7 +92,7 @@ public class MessagePersister implements Managed {
}
queuesPersisted += queuesToPersist.size();
} while (queuesToPersist.size() == QUEUE_BATCH_LIMIT);
} while (queuesToPersist.size() >= QUEUE_BATCH_LIMIT);
queueCountHistogram.update(queuesPersisted);
}