code: function(envelope, $done) {
      var __pushJob = _.bind(pushNewJob, null, envelope)
        , flow = [__pushJob]
  
      if (envelope.id) {
        var __rmJob = _.bind(removeMappedJob, null, envelope.jobType, envelope.id)
        flow = [__rmJob].concat(flow)
      }
  
      async.series(flow, function(err, results) {
        var _job = results.length > 1 ? results[1] : results[0]
          , _rm = results.length > 1 ? results[0] : null
  
        if (_rm)
          LOG.info(['Replaced old job [', envelope.id, ']'].join(' '));
  
        $done(err, _job)
      })
    }
docs: /* envelope:
  jobType: a <String> job type for kue
  jobData: payload to be saved w/ job in redis
  [id]: our "custom" id for later reterival
  [when]: a timestamp (in milliseconds) when the job should run (in UTC)