Skip to main content
Home
Browse packagesDocsSign in
This release is 7 versions behind 1.9.1 — the latest version of @fedify/amqp. Jump to latest

@fedify/amqp@1.8.9
Built and signed on GitHub Actions

fedify-dev/fedify

AMQP/RabbitMQ driver for Fedify

This package works with Node.js, Deno, Bun
This package works with Node.js
This package works with Deno
This package works with Bun
JSR Score
100%
Published
3 months ago (1.8.9)
class AmqpMessageQueue
implements MessageQueue

A message queue that uses AMQP.

Examples

Example 1

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
});

Constructors

new
AmqpMessageQueue(
connection: ChannelModel,
)

Creates a new AmqpMessageQueue.

Properties

Methods

enqueue(
message: any,
options?: MessageQueueEnqueueOptions,
): Promise<void>
enqueueMany(
messages: any[],
options?: MessageQueueEnqueueOptions,
): Promise<void>
listen(
handler: (message: any) => void | Promise<void>,
options?: MessageQueueListenOptions,
): Promise<void>

New Ticket: Report package

Please provide a reason for reporting this package. We will review your report and take appropriate action.

Please review the JSR usage policy before submitting a report.

Add Package

deno add jsr:@fedify/amqp

Import symbol

import { AmqpMessageQueue } from "@fedify/amqp";
or

Import directly with a jsr specifier

import { AmqpMessageQueue } from "jsr:@fedify/amqp";

Add Package

pnpm i jsr:@fedify/amqp
or (using pnpm 10.8 or older)
pnpm dlx jsr add @fedify/amqp

Import symbol

import { AmqpMessageQueue } from "@fedify/amqp";

Add Package

yarn add jsr:@fedify/amqp
or (using Yarn 4.8 or older)
yarn dlx jsr add @fedify/amqp

Import symbol

import { AmqpMessageQueue } from "@fedify/amqp";

Add Package

vlt install jsr:@fedify/amqp

Import symbol

import { AmqpMessageQueue } from "@fedify/amqp";

Add Package

npx jsr add @fedify/amqp

Import symbol

import { AmqpMessageQueue } from "@fedify/amqp";

Add Package

bunx jsr add @fedify/amqp

Import symbol

import { AmqpMessageQueue } from "@fedify/amqp";