Merge pull request #750 from jojihere/master

store multiple instances of jobs in jobs id map to emit events for all

Author: behrad

lib/queue/events.js

@@ -34,7 +34,12 @@ exports.key = 'events';
 exports.callbackQueue = [];
 
 exports.add = function( job, callback ) {
-  if( job.id ) exports.jobs[ job.id ] = job;
+  if( job.id ) {
+    if(!exports.jobs[ job.id ])
+      exports.jobs[ job.id ] = [];
+
+    exports.jobs[ job.id ].push(job);
+  }
 //  if (!exports.subscribed) exports.subscribe();
   if( !exports.subscribeStarted ) exports.subscribe();
   if( !exports.subscribed ) {
@@ -95,10 +100,13 @@ exports.onMessage = function( channel, msg ) {
   msg = JSON.parse(msg);
 
   // map to Job when in-process
-  var job = exports.jobs[ msg.id ];
-  if( job ) {
-    job.emit.apply(job, msg.args);
-    if( [ 'complete', 'failed' ].indexOf(msg.event) !== -1 ) exports.remove(job);
+  var jobs = exports.jobs[ msg.id ];
+  if( jobs && jobs.length > 0 ) {
+    for (var i = 0; i < jobs.length; i++) {
+      var job = jobs[i];
+      job.emit.apply(job, msg.args);
+      if( [ 'complete', 'failed' ].indexOf(msg.event) !== -1 ) exports.remove(job);
+    }
   }
   // emit args on Queues
   msg.args[ 0 ] = 'job ' + msg.args[ 0 ];