process.js

async function track (msg) {
  return Promise.resolve(foo) // intentially triggering ReferenceError for undefined `foo`
}

function process (msg, done) {
  
  try {
    track(msg).then(res => done(null, reqs)).catch(err => done(err, reqs))
  } catch (e) {
    err.code = 'INTERNAL'
    err.retry = true
    return done(err)
  }
}

function onMessage (msg) {
  process(msg, (err, res) => {
     // log err/res to datadog or whatever...
    if (err) {
      console.log(err.code) // undefined
      stats.err(err)
    } else {
      stats.success(res)
    }
  })
}