@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].

[AmqpMessageQueueOptions] https://jsr.io/@fedify/amqp/doc/mq/~/AmqpMessageQueueOptions

Installation

Deno

deno add @fedify/amqp

Node.js

npm install @fedify/amqp

Bun

bun add @fedify/amqp

Changelog

Version 0.3.0

To be released.

• Added nativeRetrial option to AmqpMessageQueueOptions to enable native retrial of messages.

• The type of the AmqpMessageQueue() constructor's first parameter has been changed from Connection to ChannelModel.

Version 0.2.0

Released on March 28, 2025.

• Added AmqpMessageQueue.enqueueMany() method for efficiently enqueuing multiple messages at once.

• Updated @js-temporal/polyfill to 0.5.0 for Node.js and Bun. On Deno, there is no change because the polyfill is not used.

Version 0.1.0

Initial release. Released on October 14, 2024.