method RabbitMqQueue.prototype.reserve
Since 0.1.0
RabbitMqQueue.prototype.reserve<T>(
name: string,
limit: number,
_nowMs: number
): Promise<readonly StoredJob<T>[]>

Reserves up to limit jobs that are due (availableAtMs <= nowMs).

CLAIMS jobs: moves them from ready set to processing set. A reserved job is not returned by subsequent reserve calls.

Type Parameters

Parameters

name: string

Job name

limit: number

Maximum jobs to reserve

_nowMs: number

Return Type

Promise<readonly StoredJob<T>[]>

The reserved jobs

Throws

Error

If the adapter is not connected

Usage

import { RabbitMqQueue } from "queue-plugin/src/index.ts";