diff --git a/router/java/src/net/i2p/router/JobQueue.java b/router/java/src/net/i2p/router/JobQueue.java index b9be0d88b83de794877360e197e266847e0ee2a0..5acde519617096f700b65d0166648d4d472900ce 100644 --- a/router/java/src/net/i2p/router/JobQueue.java +++ b/router/java/src/net/i2p/router/JobQueue.java @@ -74,7 +74,7 @@ public class JobQueue { /** default max # job queue runners operating */ private final static int DEFAULT_MAX_RUNNERS = 1; - /** router.config parameter to override the max runners @deprecated unimplemented */ + /** router.config parameter to override the max runners */ private final static String PROP_MAX_RUNNERS = "router.maxJobRunners"; /** how frequently should we check and update the max runners */ @@ -300,7 +300,7 @@ public class JobQueue { public void allowParallelOperation() { _allowParallelOperation = true; - runQueue(RUNNERS); + runQueue(_context.getProperty(PROP_MAX_RUNNERS, RUNNERS)); } /** @deprecated do you really want to do this? */