if(err) {
          subR.lpush([conf.queue.retry, msg], empty);
          subR.lpush([conf.queue.error, JSON.stringify(err)], empty);
        } else {