Event handlers for Queue.

lib/Queue/index.js

@@ -1,3 +1,6 @@
+var util = require('util');
+var EventEmitter = require('events').EventEmitter;
+
 var Monq = require('monq');
 
 var Queue = function( config ) {
@@ -10,20 +13,32 @@ var Queue = function( config ) {
     var me = this;
     if (typeof(dbName) === 'string') var dbName = [ dbName ];
 
-    console.log(dbName);
-    console.log(typeof(dbName) );
-
     me._worker = self._monq.worker( dbName );
+
+    // TODO: consider attaching only on start?
+    me._worker.on('dequeued', function (data) {
+      me.emit( 'dequeued', data );
+    });
+    me._worker.on('failed', function (data) {
+      me.emit( 'failed' , data );
+    });
+    me._worker.on('complete', function (data) {
+      me.emit( 'complete' , data );
+    });
+    me._worker.on('error', function (err) {
+      me.emit( 'error' , err );
+    });
+
   };
 
+  util.inherits( self.Worker , EventEmitter );
+
   self.Worker.prototype.register = function( processors ) {
-    var me = this;
-    me._worker.register( processors );
+    this._worker.register( processors );
   }
 
   self.Worker.prototype.start = function() {
-    var me = this;
-    me._worker.start();
+    this._worker.start();
   }
 
 };

worker.js

@@ -15,4 +15,17 @@ var worker = new queue.Worker( config.database.name );
 
 worker.register( processors );
 
+worker.on('dequeued', function (data) {
+  console.log('worker dequeued job %s', data._id );
+});
+worker.on('failed', function (data) {
+  console.log('job %s failed', data._id , data.data );
+});
+worker.on('complete', function (data) {
+  console.log('job %s complete', data._id );
+});
+worker.on('error', function (err) {
+  console.log('worker error', err );
+});
+
 worker.start();