squaremo/amqp.node
Amqp.node
amqp.node is a Node.js client and asynchronous messaging middleware designed for communicating with message brokers using the AMQP 0-9-1 protocol. It enables the creation of decoupled, event-driven architectures where independent components exchange data via queues and exchanges.
The library features a multiplexed channel manager that operates multiple logical communication streams over a single persistent connection. It includes stateful connection recovery tools that automatically restore broken network links and re-establish message consumers after service interruptions.
The implementation covers binary protocol framing, non-blocking asynchronous input and output operations, and a centralized error routing system that captures synchronous exceptions from event listeners.
Features
- AMQP Protocol Clients - Provides a full AMQP protocol client for Node.js to manage connections and data exchange.
- AMQP - Implements the AMQP 0-9-1 wire protocol for encoding and decoding messages.
- Messaging Middleware - Acts as asynchronous messaging middleware for routing and processing streams in decoupled architectures.
- Connection State Recovery - Tracks previous network state to automatically restore connections and re-establish message consumers.
- Automatic Connection Recovery - Automatically detects broken communication channels and re-establishes them to maintain availability.
- Event-Driven Architectures - Facilitates the creation of decoupled systems where components communicate via queues and exchanges.
- Multiplexed Message Streams - Handles high-volume data streams using multiplexed channels and non-blocking I/O.
- Binary Protocols - Implements binary framing for efficient data transmission and stream multiplexing.
- Connection Multiplexing - Operates multiple logical communication channels over a single physical TCP connection.
- Network Reliability - Ensures stable network links through automatic connection recovery and consumer restoration.
- Non-Blocking Socket I/O - Uses non-blocking socket I/O to handle network communication without freezing the event loop.
- Virtual Channel Multiplexing - Manages multiple logical streams over a single persistent AMQP connection via virtual channel multiplexing.
- Task Queues - AMQP 0-9-1 client for RabbitMQ.
