@taskforcesh/bullmq-pro - v7.35.2
    Preparing search index...

    Class WorkerPro<DataType, ResultType, NameType>

    Worker

    Type Parameters

    • DataType = any
    • ResultType = any
    • NameType extends string = string

    Hierarchy

    Index

    Constructors

    Properties

    Methods

    Constructors

    Properties

    RateLimitError: () => Error = Worker.RateLimitError

    Methods

    • Overrides the rate limit so that it becomes active for the given group.

      Parameters

      • job: JobPro

        Job currently being processed, and whose group we want to rate limit.

      • expireTimeMs: number

        Expire time in ms of this rate limit.

      Returns Promise<void>