amqp

@fedify/amqp: AMQP/RabbitMQ driver for Fedify

Note

Although it's theoretically possible to be used with any AMQP 0-9-1 broker, this package is primarily designed for and tested with RabbitMQ.

This package provides Fedify's MessageQueue implementation for AMQP, which is supported by RabbitMQ:

• AmqpMessageQueue

Here is an example of how to use it:

import { createFederation } from "@fedify/fedify";
import { AmqpMessageQueue } from "@fedify/amqp";
import { connect } from "amqplib";

const federation = createFederation({
  queue: new AmqpMessageQueue(await connect("amqp://localhost")),
  // ... other configurations
});

The AmqpMessageQueue constructor accepts options as the second parameter, which can be used to configure the message queue:

new AmqpMessageQueue(await connect("amqp://localhost"), {
  queue: "my_queue",
})

For more details, please refer to the docs of AmqpMessageQueueOptions.

Installation

deno add jsr:@fedify/amqp  # Deno
npm  add     @fedify/amqp  # npm
pnpm add     @fedify/amqp  # pnpm
yarn add     @fedify/amqp  # Yarn
bun  add     @fedify/amqp  # Bun