Skip to content

Commit

Permalink
Merge pull request #75 from MolecularMatch/master
Browse files Browse the repository at this point in the history
Problem deleting queue.  Queue isn't removed from list of queues.
  • Loading branch information
evantahler committed May 17, 2015
2 parents 8bd3051 + 68c4c9f commit 387a9f7
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion lib/queue.js
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,10 @@ queue.prototype.queues = function(callback){
queue.prototype.delQueue = function(q, callback){
var self = this;
self.connection.redis.del(self.connection.key('queue', q), function(err){
callback(err);
if(err) return callback(err)
self.connection.redis.srem(self.connection.key('queues'), q, function(err){
callback(err);
})
});
};

Expand Down

0 comments on commit 387a9f7

Please sign in to comment.