QueueAdapter - queue documentation

interface QueueAdapter

Queue adapter interface for low-level queue operations.

Methods



send<T>(queue: string,
data: T,
options?: SendOptions,
): Promise<string>



receive<T>(queue: string,
count?: number,
): Promise<QueueMessage<T>[]>



ack(queue: string,
...ids: string[],
): Promise<void>



nack(queue: string,
id: string,
options?: NackOptions,
): Promise<void>



close(): Promise<void>