resume.js

var taskComplete = q.defer();

queue.pop(taskComplete.promise).then(function (message) {
   var tasks = transcode(message).then(torrentize).then(makePreviews);
   
   // This will basically pipe the output of everything we're doing into the taskComplete promise...
   // so if tasks is rejected, the message will be put back into the queue and we'll receive it
   // again in this callback
   taskComplete.resolve(tasks);
});