JobQueuePublisher.push() method

Enqueues one job, optionally delayed or time-limited.

Signature:

push(job: T, options?: PushOptions): JobQueuePublisher<T>;

Parameters

Parameter

Type

Description

job

T

the job body, of whatever type this queue carries

options

PushOptions

(Optional) when the job may run, and how long it stays retriable

Returns:

JobQueuePublisher<T>

this queue, for chaining

Remarks

Fire-and-forget, and worth being deliberate about: this returns synchronously without waiting for the broker to accept the job, and a failed enqueue is reported only by logging [JobQueue] push error: through JobQueueOptions.logger. It neither throws nor hands back anything to await, so a caller that must know the job was really enqueued cannot learn it from here — watch the log, or check for the job's effects.

There is no need to start() a publisher first; the underlying send opens the connection on demand.

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