some boundary cases for the queue pumper's wait time
This commit is contained in:
@ -435,6 +435,10 @@ public class JobQueue {
|
|||||||
|
|
||||||
awaken(toAdd.size());
|
awaken(toAdd.size());
|
||||||
} else {
|
} else {
|
||||||
|
if (timeToWait < 100)
|
||||||
|
timeToWait = 100;
|
||||||
|
if (timeToWait > 10*1000)
|
||||||
|
timeToWait = 10*1000;
|
||||||
if (_log.shouldLog(Log.DEBUG))
|
if (_log.shouldLog(Log.DEBUG))
|
||||||
_log.debug("Waiting " + timeToWait + " before rechecking the timed queue");
|
_log.debug("Waiting " + timeToWait + " before rechecking the timed queue");
|
||||||
try {
|
try {
|
||||||
|
Reference in New Issue
Block a user