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

Retrieves messages from a queue (pull-based). @default count: 10

Type Parameters

Parameters

queue: string
optional
count: number = 10

Return Type

Promise<QueueMessage<T>[]>

Usage

import { RabbitMQAdapter } from ".";