Method constructor

index.js:7–547

(options = {})

const EventEmitter = require("events").EventEmitter;
class RedisSMQ extends EventEmitter {
    constructor(options = {}) {
        super(options);
        this.asyncify = (methodKey) => {
            const asyncMethodKey = methodKey + "Async";
            this[asyncMethodKey] = (...args) => {
                return new Promise((resolve, reject) => {
                    this[methodKey](...args, (err, result) => {
                        if (err) {
                            reject(err);
                            return;
                        }
                        resolve(result);
                    });
                });
            };
        };
        this.quit = (cb) => {
            if (cb === undefined) {
                cb = () => { };
            }
            this.redis.quit(cb);
        };
        this._getQueue = (qname, uid, cb) => {
            const mc = [
                ["hmget", `${this.redisns}${qname}:Q`, "vt", "delay", "maxsize"],
                ["time"]
            ];
            this.redis.multi(mc).exec((err, resp) => {
                if (err) {
                    this._handleError(cb, err);
                    return;
                }
                if (resp[0][0] === null || resp[0][1] === null || resp[0][2] === null) {
                    this._handleError(cb, "queueNotFound");
                    return;
                }
                const ms = this._formatZeroPad(Number(resp[1][1]), 6);
                const ts = Number(resp[1][0] + ms.toString(10).slice(0, 3));
                const q = {
                    vt: parseInt(resp[0][0], 10),
                    delay: parseInt(resp[0][1], 10),
                    maxsize: parseInt(resp[0][2], 10),
                    ts: ts
                };
                if (uid) {
                    uid = this._makeid(22);
                    q.uid = Number(resp[1][0] + ms).toString(36) + uid;
                }
                cb(null, q);
            });
        };
        this.changeMessageVisibility = (options, cb) => {
            if (this._validate(options, ["qname", "id", "vt"], cb) === false)
                return;
            this._getQueue(options.qname, false, (err, q) => {
                if (err) {
                    this._handleError(cb, err);
                    return;