Permalink
Browse files

Fixed multiple event emitting. Closes #73

  • Loading branch information...
1 parent dc4db8f commit df7533cc8957afa634a757d63272a95f60800757 @vetrovosk vetrovosk committed Sep 23, 2011
Showing with 1 addition and 0 deletions.
  1. +1 −0 lib/queue/events.js
View
@@ -44,6 +44,7 @@ exports.add = function(job){
*/
exports.subscribe = function(){
+ if (exports.subscribed) return;
var client = pool.pubsubClient();
client.subscribe(exports.key);
client.on('message', exports.onMessage);

0 comments on commit df7533c

Please sign in to comment.