diff --git a/lib/queue.js b/lib/queue.js
index 7df84ef4e..1918c60a0 100644
--- a/lib/queue.js
+++ b/lib/queue.js
@@ -522,6 +522,9 @@ Queue.prototype.processStalledJob = function() {
   return scripts.getStalledJob(this).then(function(job){
     if (job) {
       return _this.getJobFromId(job).then(function(job){
+        if (job.started) {
+          _this.emit('stalled', job);
+        }
         return _this.processJob(job, true /* Renew the lock */);
       });
     }