test for custom job check interval

timgit · Mar 14, 2017 · 6fc942d · 6fc942d
1 parent 479ac92
commit 6fc942d
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 1 deletion.
diff --git a/src/manager.js b/src/manager.js
@@ -94,7 +94,7 @@ class Manager extends EventEmitter {
                 options.teamSize = options.teamSize || 1;
 
                 if('newJobCheckInterval' in options || 'newJobCheckIntervalSeconds' in options)
-                  Attorney.applyNewJobCheckInterval(options);
+                  options = Attorney.applyNewJobCheckInterval(options);
                 else
                   options.newJobCheckInterval = self.config.newJobCheckInterval;
 

diff --git a/test/subscribeTest.js b/test/subscribeTest.js
@@ -38,6 +38,25 @@ describe('subscribe', function(){
         });
     });
 
+    it('should honor a custom new job check interval', function(finished){
+      this.timeout(5000);
+
+      let startTime = new Date();
+      const newJobCheckIntervalSeconds = 3;
+
+      boss.subscribe('foo', {newJobCheckIntervalSeconds}, (job, done) => {
+        let elapsed = new Date().getTime() - startTime.getTime();
+
+        assert.isAbove((elapsed / 1000), newJobCheckIntervalSeconds);
+
+        done()
+          .then(() => finished());
+
+      }).then(() => {
+        boss.publish('foo');
+      });
+
+    });
 
 });