amqplib

library1.0.2jsnpmunverified

amqplib is a robust and widely-used library for building AMQP 0-9-1 clients in Node.js, specifically designed for interaction with brokers like RabbitMQ. Currently stable at version 1.0.3, it offers both a traditional callback-based API and a modern Promise/async-await API, catering to diverse asynchronous programming styles. The library generally maintains a consistent release cadence, incorporating updates and compatibility fixes. A key differentiator is its comprehensive implementation of the AMQP 0-9-1 protocol, covering both high-level and low-level functionalities, ensuring full control over message queuing operations. It explicitly does not support AMQP 1.0 or AMQP 0-10, focusing solely on the 0-9-1 specification. It is actively maintained, stable, and used in production environments, with ongoing efforts to improve test coverage and performance. Its minimal dependencies make it a lean choice for AMQP communication.

database http-networking communication

npm install amqplib

github ↗package ↗homepage ↗

INSTALL

IMPORT

SIG · AMQPLIB

amqplib

databasejavascriptv1.0.2

Install

—

Import

—

Disk

—

Pass rate

0/ 6

Env Coverage0 / 6

glibc

18–22

musl

18–22

Install & Compatibility

Where this runs

tested against v? · npm install

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

node 18–226 runs

build_error

glibc

node 18–226 runs

build_error

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

connect

✓ import { connect } from 'amqplib';

✗ const amqplib = require('amqplib');

For the Promise-based API in an ESM module (Node.js >=18). The module exports an object with a 'connect' function.

callback_api connect

✓ import { connect as connectCallback } from 'amqplib/callback_api';

✗ const amqpCallback = require('amqplib/callback_api');

For the traditional callback-based API in an ESM module. Access the 'connect' function, aliased to avoid collision.

Types

✓ import type { Channel, Connection, ConsumeMessage } from 'amqplib';

✗ import { Channel, Connection, ConsumeMessage } from 'amqplib';

Import types for enhanced TypeScript development. The library ships with type definitions.

Demonstrates connecting to RabbitMQ, setting up a queue, and both publishing and consuming messages using the modern Promise/Async API.

import { connect } from 'amqplib'; (async () => { const queue = 'tasks'; let connection; try { connection = await connect('amqp://localhost'); const channel = await connection.createChannel(); await channel.assertQueue(queue, { durable: false }); // Listener (Consumer) channel.consume(queue, (msg) => { if (msg !== null) { console.log('Received message:', msg.content.toString()); channel.ack(msg); } else { console.log('Consumer cancelled by server'); } }, { noAck: false }); console.log('Waiting for messages in %s. To exit press CTRL+C', queue); // Sender (Producer) const senderChannel = await connection.createChannel(); setInterval(() => { const message = `Task update: ${new Date().toISOString()}`; senderChannel.sendToQueue(queue, Buffer.from(message)); console.log('Sent:', message); }, 2000); } catch (error) { console.error('Failed to connect to RabbitMQ or perform operations:', error); if (connection) { await connection.close(); } process.exit(1); } })();

Debug

Known issues

breakingAs of version 1.0.3, `amqplib` officially requires Node.js version 18 or higher due to its `engines` declaration. Older versions (e.g., v0.8.0) dropped support for Node.js < v10, but the current major version has further increased this baseline requirement.

fix

Ensure your Node.js environment is version 18 or newer. Update Node.js or use a tool like `nvm` to manage versions.

affects: >=1.0.0

gotchaFor compatibility with RabbitMQ 4.1.0 and later releases, `amqplib` versions 0.10.7 or newer are required. Using older `amqplib` versions with newer RabbitMQ might lead to protocol mismatches or unexpected behavior.

fix

Upgrade `amqplib` to version 0.10.7 or newer if you are using RabbitMQ 4.1.0 or a later version.

affects: <0.10.7

gotcha`amqplib` strictly adheres to the AMQP 0-9-1 protocol specification. It explicitly does not implement or support AMQP 1.0 or AMQP 0-10. Attempting to connect to brokers expecting these different protocol versions will fail.

fix

Verify that your AMQP broker (e.g., RabbitMQ) is configured for AMQP 0-9-1. If you require AMQP 1.0, consider an alternative library that specifically supports that protocol.

affects: *

gotchaWhen running tests or connecting to remote/public RabbitMQ instances, network latency or server load can lead to connection timeouts. This is particularly noted with instances like `dev.rabbitmq.com`.

fix

Increase connection timeout settings if available, ensure stable network connectivity, or use a local RabbitMQ instance for development and testing to reduce latency.

affects: *

Errors

Common errors & fixes

Error: connect ECONNREFUSED 127.0.0.1:5672

The `amqplib` client could not establish a connection to the RabbitMQ server, likely because the server is not running or is inaccessible at the specified address and port.

fix

Ensure your RabbitMQ server is running and accessible from the machine where your Node.js application is executing. Check the host and port in your connection string (e.g., `amqp://localhost:5672`).

ReferenceError: require is not defined

You are attempting to use the CommonJS `require` syntax in an ES Module (ESM) context (e.g., a `.mjs` file or a `.js` file in a project with `"type": "module"` in `package.json`).

fix

Switch to ESM `import` statements (e.g., `import { connect } from 'amqplib';`) or ensure your file is treated as a CommonJS module (e.g., rename to `.cjs` or remove `"type": "module"` from `package.json`).

Error: Channel closed

An operation was attempted on an AMQP channel that has already been closed, either explicitly by your code or implicitly by an error on the broker side.

fix

Implement proper error handling for channel operations and ensure you are not attempting to reuse a closed channel. Recreate the channel if necessary after it has closed.

Error: Incompatible protocol version. Client sent 0-9-1, server sent X-Y-Z

`amqplib` (0-9-1) is attempting to connect to an AMQP broker that is expecting a different protocol version.

fix

Verify the AMQP protocol version expected by your broker and ensure it is 0-9-1. If using RabbitMQ, check its version compatibility (e.g., `amqplib` 0.10.7+ for RabbitMQ 4.1.0+).

Upgrade

Version history

1.0.2latest on npm

Audit

Dependencies

No dependency data recorded yet.

Agent activity

48 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/amqp-node/amqplib ↗

packagehttps://www.npmjs.com/package/amqplib ↗

homepagehttp://amqp-node.github.io/amqplib/ ↗