콘텐츠로 이동

JobQueue

Defined in: packages/messaging/src/queue/job-queue.interface.ts:26

T

clear(): Promise<void>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:56

Promise<void>


complete(jobId, result?): Promise<void>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:40

string

any

Promise<void>


dequeue(): Promise<Job<T> | undefined>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:38

Promise<Job<T> | undefined>


enqueue(type, data, options?): Promise<Job<T>>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:27

string

T

number

number

Record<string, any>

number

Promise<Job<T>>


fail(jobId, error, shouldRetry?): Promise<void>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:42

string

string | Error

boolean

Promise<void>


getJob(jobId): Promise<Job<T> | undefined>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:52

string

Promise<Job<T> | undefined>


peek(): Promise<Job<T> | undefined>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:48

Promise<Job<T> | undefined>


remove(jobId): Promise<boolean>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:54

string

Promise<boolean>


size(): Promise<number>

Defined in: packages/messaging/src/queue/job-queue.interface.ts:50

Promise<number>