Class BullWebhookQueue

Bull webhook queue implementation

Hierarchy (View Summary)

BullBaseQueue
- BullWebhookQueue

Implements

WebhookQueue

Constructors

constructor

new BullWebhookQueue(
    config: Config<BullProduceConfig>,
    logger: Logger,
    connector: ProduceConnector,
): BullWebhookQueue
Parameters
- config: Config<BullProduceConfig>
- logger: Logger
- connector: ProduceConnector
Returns BullWebhookQueue
Overrides BullBaseQueue.constructor
- Defined in packages/produce/src/modules/webhook/bull-webhook.queue.ts:26

Methods

addJob

addJob(name: string, data: WebhookJobData): Promise<void>
Add job to queue
Parameters
- name: string
- data: WebhookJobData
Returns Promise<void>
Implementation of WebhookQueue.addJob
- Defined in packages/produce/src/modules/webhook/bull-webhook.queue.ts:32

close

close(): Promise<void>
Close queue

Returns Promise<void>
Implementation of WebhookQueue.close
Inherited from BullBaseQueue.close
- Defined in packages/produce/src/modules/base/bull-base.queue.ts:47

getJobCount

getJobCount(): Promise<number>
Get job cound

Returns Promise<number>
Implementation of WebhookQueue.getJobCount
Inherited from BullBaseQueue.getJobCount
- Defined in packages/produce/src/modules/base/bull-base.queue.ts:53

getJobCounts

getJobCounts(): Promise<Record<string, number>>
Get job counts

Returns Promise<Record<string, number>>
Implementation of WebhookQueue.getJobCounts
Inherited from BullBaseQueue.getJobCounts
- Defined in packages/produce/src/modules/base/bull-base.queue.ts:61

`Static`register

register(container: DIContainer): void
Register dependency
Parameters
- container: DIContainer
Returns void
- Defined in packages/produce/src/modules/webhook/bull-webhook.queue.ts:18