Skip to main content

JobConsumer

@forge/monorepo


@forge/monorepo / backend/src / JobConsumer

Interface: JobConsumer

Defined in: backend/src/worker/main.ts:36

The queue's consumer side.

stop must stop accepting new jobs immediately and only then wait for in-flight handlers. An implementation that drains first would accept a job it has no intention of finishing.

Methods

start()

start(handler): void | Promise<void>

Defined in: backend/src/worker/main.ts:37

Parameters

handler

(job) => Promise<void>

Returns

void | Promise<void>


stop()

stop(graceMs): Promise<void>

Defined in: backend/src/worker/main.ts:38

Parameters

graceMs

number

Returns

Promise<void>