dbqueue - npm Package Compare versions

Comparing version 3.0.1 to 3.0.2

main.js

@@ -106,4 +106,5 @@ 'use strict';
 DBQueue.prototype.consume = function(queue_input, options_input, done_input) {
-  var db   = this.db;
-  var self = this;
+  var db    = this.db;
+  var table = this.table;
+  var self  = this;
 
@@ -137,3 +138,3 @@ var options;
 
-        db.query("DELETE FROM jobs WHERE id = ?", [job.id], function(err, result) {
+        db.query("DELETE FROM ?? WHERE id = ?", [table, job.id], function(err, result) {
           if (err) {
@@ -140,0 +141,0 @@ console.error('Error acking message:', err, err.stack);

package.json

 {
   "name": "dbqueue",
-  "version": "3.0.1",
+  "version": "3.0.2",
   "description": "A minimal, durable DB-based message queue system",
@@ -5,0 +5,0 @@ "homepage": "https://github.com/elliotf/node-dbqueue",

test/main.js

@@ -758,3 +758,11 @@ 'use strict';
 
-                    return done();
+                    completionCallback(null);
+                    setTimeout(function () {
+                      db.query('SELECT * FROM custom_jobs_table', function(err, rows) {
+                        expect(err).to.not.exist();
+                        expect(rows).to.have.length(0);
+                        return done();
+                      });
+                    }, 10);
+
                   });
@@ -761,0 +769,0 @@ });

No alert changes

Improved metrics

Total package byte prevSize

42140

increased by0.91%

Lines of code

925

increased by0.87%

No dependency changes