function createRabbitMQ
createRabbitMQ(options?: string | RabbitMQQueueOptions): RabbitMQConnector

Creates a RabbitMQ queue connector.

Examples

Example 1

const connector = createRabbitMQ("amqp://localhost:5672");
// or with options:
const connector = createRabbitMQ({
  connection: "amqp://localhost:5672",
  prefix: "my-app",
  queues: { notifications: { maxAttempts: 3 } }
});

Parameters

optional
options: string | RabbitMQQueueOptions

Connection string or configuration options

Return Type

Usage

import { createRabbitMQ } from ".";