RabbitMQAdapter.prototype.subscribe - default - queue-rabbitmq documentation

method RabbitMQAdapter.prototype.subscribe



RabbitMQAdapter.prototype.subscribe<T>(queue: string,
options?: { signal?: AbortSignal; prefetch?: number;  }
): AsyncIterable<QueueMessage<T>>

Subscribes to messages from a queue (push-based).

Type Parameters



queue: string

optional



options: { signal?: AbortSignal; prefetch?: number;  }

AsyncIterable<QueueMessage<T>>

import { RabbitMQAdapter } from ".";