Documentation / @tenancy-node/core / MemoryQueue

Class: MemoryQueue

Defined in: core/src/queue/memory-queue.ts:27

Cola en memoria del proceso. Útil en desarrollo y tests: se pierde al reiniciar. En producción usa @tenancy-node/queue-bullmq.

Implements

• QueueDriver

Constructors

Constructor

new MemoryQueue(): MemoryQueue

Returns

MemoryQueue

Properties

name

readonly name: "memory" = 'memory'

Defined in: core/src/queue/memory-queue.ts:28

Implementation of

QueueDriver.name

Accessors

size

Get Signature

get size(): number

Defined in: core/src/queue/memory-queue.ts:69

Returns

number

Methods

close()

close(): Promise<void>

Defined in: core/src/queue/memory-queue.ts:73

Returns

Promise<void>

Implementation of

QueueDriver.close

---

drain()

drain(): Promise<void>

Defined in: core/src/queue/memory-queue.ts:64

Espera a que no queden trabajos pendientes ni en curso (tests).

Returns

Promise<void>

---

enqueue()

enqueue(job): Promise<string>

Defined in: core/src/queue/memory-queue.ts:39

Parameters

job

NewJob

Returns

Promise<string>

Implementation of

QueueDriver.enqueue

---

process()

process(processor, options): Promise<QueueWorker>

Defined in: core/src/queue/memory-queue.ts:50

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

Parameters

processor

JobProcessor

options

concurrency

number

Returns

Promise<QueueWorker>

Implementation of

QueueDriver.process