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)
interface AmqpMessageQueueOptions

Options for AmqpMessageQueue.

Properties

optional
queue: string

The name of the queue to use. Defaults to "fedify_queue".

The prefix to use for the delayed queue. Defaults to "fedify_delayed_". Defaults to "fedify_delayed_".

optional
durable: boolean

Whether the queue will survive a broker restart. Defaults to true.

Whether to use native retrial mechanism. If set to true, the queue will not acknowledge messages that are not processed successfully, allowing them to be retried later. If set to false, messages will be acknowledged whether they are processed successfully or not.

Both approaches have their own advantages and disadvantages. With native retrials, much less chance of losing messages, but timing of retrials is less predictable. With non-native retrials, retrials are handled by Fedify itself, which allows for more control over the timing and behavior of retrials, but may result in lost messages if the process crashes before acknowledging the message.

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 { type AmqpMessageQueueOptions } from "@fedify/amqp";
or

Import directly with a jsr specifier

import { type AmqpMessageQueueOptions } 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 { type AmqpMessageQueueOptions } 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 { type AmqpMessageQueueOptions } from "@fedify/amqp";

Add Package

vlt install jsr:@fedify/amqp

Import symbol

import { type AmqpMessageQueueOptions } from "@fedify/amqp";

Add Package

npx jsr add @fedify/amqp

Import symbol

import { type AmqpMessageQueueOptions } from "@fedify/amqp";

Add Package

bunx jsr add @fedify/amqp

Import symbol

import { type AmqpMessageQueueOptions } from "@fedify/amqp";