Class WorkQueueApiPublisher

Implements

IWorkPublisher

Index

Constructors

Methods

Constructors

constructor

new WorkQueueApiPublisher(
options: WorkQueueApiPublisherOptions,
): WorkQueueApiPublisher
Parameters
- options: WorkQueueApiPublisherOptions
Returns WorkQueueApiPublisher
- Defined in packages/WorkQueue/core/src/api/WorkQueueApiPublisher.ts:56

Methods

Publish

Publish<TPayload extends WorkJson>(
topic: string,
requests: PublishRequest<TPayload>[],
): Promise<PublishResult[]>
Batch publish. Results are positionally aligned with requests. Partial success is possible.
Type Parameters
- TPayload extends WorkJson
Parameters
- topic: string
- requests: PublishRequest<TPayload>[]
Returns Promise<PublishResult[]>
Implementation of IWorkPublisher.Publish
- Defined in packages/WorkQueue/core/src/api/WorkQueueApiPublisher.ts:66