Merge pull request #29 from mvdriel/make-find-limit-during-request-jo…

…b-configurable Make find limit during request job configurable
Oefenweb · Nov 6, 2015 · b01dd9f · b01dd9f
2 parents 5873e1a + 4bd8444
commit b01dd9f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/Console/Command/QueueShell.php b/Console/Command/QueueShell.php
@@ -74,6 +74,7 @@ public function initialize() {
 		// Merge with default configuration vars.
 		Configure::write('Queue', array_merge(
 				array(
+					'workers' => 3,
 					'sleepTime' => 10,
 					'gcprop' => 10,
 					'defaultWorkerTimeout' => 2 * MINUTE,

diff --git a/Model/QueuedTask.php b/Model/QueuedTask.php
@@ -62,7 +62,7 @@ public function requestJob($capabilities) {
 			'age' => 'ASC',
 			'id' => 'ASC'
 		);
-		$limit = 3;
+		$limit = Configure::read('Queue.workers');
 
 		// Generate the job specific conditions.
 		foreach ($capabilities as $task) {

diff --git a/README.md b/README.md
@@ -22,6 +22,7 @@ CakePlugin::load('Queue');
 Ensure to configure the following lines in `app/Config/bootstrap.php`:
 
 ```
+Configure::write('Queue.workers', 3);
 Configure::write('Queue.sleepTime', 10);
 Configure::write('Queue.gcprop', 10);
 Configure::write('Queue.defaultWorkerTimeout', 2 * MINUTE);