} catch(e) {
    subR.lpush([conf.queue.retry, msg], empty);
    subR.lpush([conf.queue.error, JSON.stringify(e)], empty);
  }