Comparing version 0.1.5 to 0.1.6
{ | ||
"name": "jqueue", | ||
"version": "0.1.5", | ||
"version": "0.1.6", | ||
"description": "MySQL backed plugable Node.js job queue based on the Beanstalk Job Lifecycle", | ||
@@ -5,0 +5,0 @@ "devDependencies": { |
@@ -1,3 +0,3 @@ | ||
var Queue = require('./queue'); | ||
var JqueueException = require('./exception'); | ||
var Queue = require('./queue'); | ||
var JqueueException = require('./exception'); | ||
var callBack = require('./callback'); | ||
@@ -12,4 +12,4 @@ | ||
function execQuery(query, params, cb) { | ||
dataSource.getConnection(function(error, connection) { | ||
if(error) { | ||
dataSource.getConnection(function (error, connection) { | ||
if (error) { | ||
cb(error); | ||
@@ -39,3 +39,3 @@ } else { | ||
status ENUM(\'ready\', \'reserved\', \'buried\') NOT NULL,\ | ||
data ?? NOT NULL,\ | ||
data ' + dataType + ' NOT NULL,\ | ||
priority TINYINT NOT NULL,\ | ||
@@ -45,3 +45,3 @@ date_time TIMESTAMP NOT NULL,\ | ||
version INT NULL DEFAULT NULL,\ | ||
PRIMARY KEY (id)) ENGINE = ??', [queueName, dataType, storageEngine], cb); | ||
PRIMARY KEY (id)) ENGINE = ??', [queueName, storageEngine], cb); | ||
} | ||
@@ -74,3 +74,3 @@ | ||
if (error) { | ||
if(noCreate) { | ||
if (noCreate) { | ||
callBack(cb, error); | ||
@@ -77,0 +77,0 @@ } else { |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
54400