diff --git a/lib/plugins/queueLock.js b/lib/plugins/queueLock.js index cd6c0488..7da76daf 100644 --- a/lib/plugins/queueLock.js +++ b/lib/plugins/queueLock.js @@ -31,10 +31,7 @@ queueLock.prototype.before_enqueue = function(callback){ callback(null, false); }else{ self.worker.connection.redis.set(key, timeout, function(err){ - self.worker.connection.redis.get(key, function(err, redisTimeout){ - redisTimeout = parseInt(redisTimeout); - callback(null, now > redisTimeout); - }); + callback(err, !err); }); } });