basalt / queue-bullmq/src / BullmqDriverOptions
Interface: BullmqDriverOptions
Defined in: queue-bullmq/src/index.ts:40
Extended by
Properties
connection
> connection: string | ConnectionOptions
Defined in: queue-bullmq/src/index.ts:42
Redis URL (redis://... or rediss://...) or ioredis connection options.
onError?
> optional onError?: (error, info) => void
Defined in: queue-bullmq/src/index.ts:49
Infra errors from BullMQ's Worker/Queue emitters (e.g. Redis down). BullMQ emits these as EventEmitter 'error' events — unhandled, they CRASH the process. Default: logged via console.error with full context — observable, never fatal, never silent. (Same pattern as realtime's onBridgeError.)
Parameters
error
unknown
info
queue
string
source
"queue" | "worker"
Returns
void
onJobFailed?
> optional onJobFailed?: (info) => void
Defined in: queue-bullmq/src/index.ts:54
A job exhausted its retries (BullMQ 'failed'). Default: console.error — without this, exhausted jobs were only visible by polling queue stats.
Parameters
info
error
unknown
job
string
jobId?
string
queue
string
Returns
void