Documentation

Documentation / @zerotal/queue / index / Bus

Class: Bus

Defined in: queue/src/Bus.ts:7

Constructors

Constructor

new Bus(): Bus

Returns

Bus

Methods

setManager()

static setManager(manager): void

Defined in: queue/src/Bus.ts:10

Parameters

manager

QueueManager

Returns

void

batch()

static batch(jobs): PendingBatch

Defined in: queue/src/Bus.ts:15

Dispatch a set of jobs as a batch. Returns a fluent builder to attach callbacks.

Parameters

jobs

Job[]

Returns

PendingBatch

chain()

static chain(jobs): object

Defined in: queue/src/Bus.ts:27

Chain jobs sequentially — each job runs only after the previous one succeeds. If any job fails the chain is stopped (no subsequent jobs are dispatched).

Parameters

jobs

Job[]

Returns

object

dispatch()

dispatch(): Promise<void>

Returns

Promise<void>

reset()

static reset(): void

Defined in: queue/src/Bus.ts:44

Reset the manager reference (for testing).

Returns

void