RabbitMQAdapter.prototype.subscribe - queue-rabbitmq documentation

method RabbitMQAdapter.prototype.subscribe



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

Type Parameters



queue: string

optional



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

AsyncIterable<QueueMessage<T>>

import { RabbitMQAdapter } from ".";