@@ -116,6 +116,24 @@ job.on('complete', function(){
 });
 ```
 
+### Queue Events
+
+ Queue-level events are currently provide access to the job-level events previously mentioned, however scoped to the `Queue` instance to to apply logic at a "global" level. An example of this is removing completed jobs:
+ 
+```js
+jobs.on('job complete', function(id){
+  Job.get(id, function(err, job){
+    if (err) return;
+    job.remove(function(err){
+      if (err) throw err;
+      console.log('removed completed job #%d', job.id);
+    });
+  });
+});
+```
+
+ The events available are the same as mentioned in "Job Events", however prefixed with "job ". 
+
 ### Delayed Jobs
 
   Delayed jobs may be scheduled to be queued for an arbitrary distance in time by invoking the `.delay(ms)` method, passing the number of milliseconds relative to _now_. This automatically flags the `Job` as "delayed". 
 
@@ -63,7 +63,7 @@ exports.redis = redis;
  */
 
 exports.createQueue = function(){
-  return new Queue;
+  return Queue.singleton = new Queue;
 };
 
 /**
 
@@ -36,6 +36,7 @@ exports.add = function(job){
   if (job.id) exports.jobs[job.id] = job;
   if (!exports.subscribed) {
     exports.subscribe();
+    exports.queue = require('../kue').singleton;
     exports.subscribed = true;
   }
 };
@@ -49,7 +50,7 @@ exports.add = function(job){
 exports.subscribe = function(){
   var client = pool.pubsubClient();
   client.subscribe(exports.key);
-  client.on('message', this.onMessage);
+  client.on('message', exports.onMessage);
 };
 
 /**
@@ -59,12 +60,21 @@ exports.subscribe = function(){
  */
 
 exports.onMessage = function(channel, msg){
-  var msg = JSON.parse(msg)
-    , job = exports.jobs[msg.id];
-  if (!job) return;
-  job.emit.apply(job, msg.args);
-  // TODO: abstract this out
-  if ('progress' != msg.event) delete exports.jobs[job.id];
+  // TODO: only subscribe on {Queue,Job}#on()
+  var msg = JSON.parse(msg);
+
+  // map to Job when in-process
+  var job = exports.jobs[msg.id];
+  if (job) {
+    job.emit.apply(job, msg.args);
+    // TODO: abstract this out
+    if ('progress' != msg.event) delete exports.jobs[job.id];
+  }
+
+  // emit args on Queues
+  msg.args[0] = 'job ' + msg.args[0];
+  msg.args.push(msg.id);
+  exports.queue.emit.apply(exports.queue, msg.args);
 };
 
 /**
 
@@ -521,11 +521,7 @@ Job.prototype.save = function(fn){
     self.update(fn);
 
     // add the job for event mapping
-    if (self.listeners('complete').length
-      + self.listeners('failed').length
-      + self.listeners('progress').length) {
-      events.add(self);
-    }
+    events.add(self);
   });
 
   return this;