Interface: TaskQueue

Definition of a connection-object that can generate queues and workers for a specific connection type (e.g. BullMQ, In-memory)

Properties

createWorker: (name, executor, options?) => Closeable

• name: string

• executor

• options?

• options.concurrency?: number

drainAllQueues: () => Promise<void>

Promise<void>

getQueue: (name) => Promise<InstantiatedQueue>

• name: string