BaseJobQueue.handleMessage() method

Handles one popped message: runs the handler, then acts on what it asked for.

Signature:

protected handleMessage(message: any, id?: string): Promise<void>;

Parameters

Parameter

Type

Description

message

any

the popped message envelope

id

string

(Optional) broker message id, for log lines

Returns:

Promise<void>

Remarks

Lives here rather than on JobQueueWorker because JobQueue consumes as well, and reaches the worker's onPop through Function.call — so the listener it installs has to find this on the instance it was called with, whichever of the two that is.

Read this page as plain markdown — no HTML, no navigation. For pasting into an LLM, or for an agent to fetch.