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

Retrieve one or more messages from the specified queue.

Type Parameters

Parameters

queue: string

Name of the queue to receive from.

optional
count: number

Maximum number of messages to retrieve in this call.

Return Type

Promise<QueueMessage<T>[]>

Array of messages retrieved from the broker.

Usage

import { type QueueAdapter } from ".";