Changed: one redis connection for all workers

now that our ZPOP does not block this is all good
Automattic · Aug 16, 2011 · 307d016 · 307d016
1 parent 95cc403
commit 307d016
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/examples/delayed.js b/examples/delayed.js
@@ -36,7 +36,7 @@ jobs.create('email', {
 
 jobs.promote();
 
-jobs.process('email', 5, function(job, done){
+jobs.process('email', 10, function(job, done){
   setTimeout(function(){
     done();
   }, Math.random() * 5000);

diff --git a/lib/queue/worker.js b/lib/queue/worker.js
@@ -32,7 +32,7 @@ module.exports = Worker;
 function Worker(queue, type) {
   this.queue = queue;
   this.type = type;
-  this.client = redis.createClient();
+  this.client = Worker.client || (Worker.client = redis.createClient());
   this.interval = 1000;
 }