From c32d806886b900d26dbe028220e36fa8accb915f Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Thu, 28 Apr 2016 15:14:44 -0700
Subject: [PATCH] make the size limit configurable

---
 src/worker.js | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/worker.js b/src/worker.js
index 9f02ccc..6135223 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -21,6 +21,7 @@ export default class Job extends events.EventEmitter {
     this.type = type;
     this.workerFn = workerFn;
     this.checkInterval = opts.interval || 1500;
+    this.checkSize = opts.size || 10;
 
     this.debug = (...msg) => debug(...msg, `id: ${this.id}`);
 
@@ -166,7 +167,7 @@ export default class Job extends events.EventEmitter {
         { priority: { order: 'asc' }},
         { created_at: { order: 'asc' }}
       ],
-      size: 10
+      size: this.checkSize
     };
 
     this.debug('querying for outstanding jobs');