Documentation / @tenancy-node/core / QueueDriver

Interface: QueueDriver

Defined in: core/src/ports/queue.ts:43

Cola de trabajos (memoria, BullMQ...). El driver se encarga de persistir, reintentar con espera y repartir entre workers.

Properties

name

readonly name: string

Defined in: core/src/ports/queue.ts:44

Methods

close()

close(): Promise<void>

Defined in: core/src/ports/queue.ts:49

Returns

Promise<void>

---

enqueue()

enqueue(job): Promise<string>

Defined in: core/src/ports/queue.ts:45

Parameters

job

NewJob

Returns

Promise<string>

---

ping()?

optional ping(): Promise<void>

Defined in: core/src/ports/queue.ts:48

Returns

Promise<void>

---

process()

process(processor, options): Promise<QueueWorker>

Defined in: core/src/ports/queue.ts:47

Empieza a procesar. Si processor lanza, el driver reintenta según las opciones del trabajo.

Parameters

processor

JobProcessor

options

concurrency

number

Returns

Promise<QueueWorker>