@types/rsmq-worker

Installation

npm install --save @types/rsmq-worker

Summary

This package contains type definitions for rsmq-worker (http://smrchy.github.io/rsmq/rsmq-worker/).

Details

Files were exported from https://github.com/DefinitelyTyped/DefinitelyTyped/tree/master/types/rsmq-worker.

index.d.ts

/// <reference types="rsmq"/>
/// <reference types="node" />

import redis = require("redis");
import events = require("events");
import RedisSMQ = require("rsmq");

declare namespace RSMQWorker {
    export interface Client extends events.EventEmitter {
        start(): Client;
        stop(): Client;
        send(message: string, delay?: number, cb?: CallbackT<string>): Client;
        send(message: string, cb: CallbackT<string>): Client;
        del(id: string, cb?: CallbackT<void>): Client;
        changeInterval(interval: number | number[]): Client;
        quit(): void;
    }

    export interface Options {
        interval?: number | undefined;
        maxReceiveCount?: number | undefined;
        invisibletime?: number | undefined;
        defaultDelay?: number | undefined;
        autostart?: boolean | undefined;
        timeout?: number | undefined;
        customExceedCheck?: CustomExceedCheckCallback | undefined;
        rsmq?: RedisSMQ.Client | undefined;
        redis?: redis.RedisClient | undefined;
        redisPrefix?: string | undefined;
        host?: string | undefined;
        port?: number | undefined;
        options?: redis.ClientOpts | undefined;
    }

    export interface CustomExceedCheckCallback {
        (message: RedisSMQ.Message): boolean;
    }

    export interface CallbackT<R> {
        (e?: Error, res?: R): void;
    }
}

interface RSMQWorkerStatic {
    new(queuename: string, options?: RSMQWorker.Options): RSMQWorker.Client;
}

declare var RSMQWorker: RSMQWorkerStatic;
export = RSMQWorker;

Additional Details

• Last updated: Fri, 24 Oct 2025 0441 GMT
• Dependencies: @types/node, @types/redis, @types/rsmq

Credits

These definitions were written by TANAKA Koichi.