streadway/amqp
Amqp
This is a Go client library and protocol implementation for interacting with message brokers using the AMQP 0.9.1 standard. It serves as an asynchronous messaging toolkit and message queue client for implementing producer and consumer patterns.
The library provides a programmatic interface for managing the full message lifecycle, including publishing, consumption, and delivery acknowledgments. It supports reliable delivery mechanisms such as publishing confirmations and atomic transactions.
The project covers the administration of routing topologies through the declaration and binding of queues and exchanges. It also includes traffic management capabilities for regulating message flow and configuring quality of service limits. Connection management is handled via URI parsing and the establishment of secure or plain text sockets.
Features
- AMQP Protocol Clients - Provides a full Go client implementation for interacting with AMQP 0.9.1 message brokers.
- AMQP - Implements the AMQP 0.9.1 standard for handling connections, channels, and binary framing.
- AMQP Client Libraries - Provides a comprehensive Go library for communicating with AMQP 0.9.1 brokers.
- Reliable Message Delivery - Ensures reliable delivery through the use of acknowledgments, publisher confirms, and atomic transactions.
- Message Consumption - Implements the process of streaming and retrieving messages from an AMQP queue.
- Queue Declarations - Provides the ability to declare message queues with specific durability and auto-deletion settings.
- Queue and Exchange Orchestration - Provides programmatic creation and configuration of named message exchanges.
- Asynchronous Messaging Clients - Provides a toolkit for implementing asynchronous producer and consumer patterns.
- Publish-Subscribe Messaging - Implements the publishing of messages to exchanges within a publish-subscribe messaging model.
- Connection Multiplexing - Implements AMQP channels to multiplex multiple virtual connections over a single physical TCP link.
- Message Delivery Guarantees - Provides mechanisms for acknowledging processed messages to ensure reliable at-least-once delivery.
- Message Queue Clients - Offers a programmatic interface for declaring queues, binding exchanges, and publishing messages.
- Binary Frame Serialization - Encapsulates AMQP messages into binary frames for efficient transmission over TCP.
- Connection Establishment - Handles the handshake and establishment process for secure or plain text TCP connections to AMQP brokers.
- Connection State Management - Tracks the lifecycle of network sockets and session authentication to maintain persistent broker connections.
- Asynchronous Event Queueing - Enables event-driven architectures by queuing events to decouple producers from consumers.
- Distributed Task Queues - Facilitates distributed task processing by spreading work across multiple consumers via queues.
- Atomic Transaction Execution - Provides the ability to group multiple publishing and acknowledgment operations into atomic transactions for consistency.
- Transactional Message Batches - Groups publishing and acknowledgment operations into atomic transactional batches.
- Message Routing - Allows configuration of complex routing topologies using exchanges and queue bindings.
- Publishing Confirmations - Allows publishers to verify that the broker has successfully received and accepted a message.
- Server-to-Client Event Emissions - Registers listeners to react to asynchronous server-to-client events such as connection closures.
- Flow Control Window Managers - Regulates message flow using prefetch limits to prevent consumer memory exhaustion.
- Pending Message Redelivery - Enables the recovery and redelivery of messages that were delivered but not acknowledged.
- Flow Controllers - Provides mechanisms to pause and resume message delivery on a channel to regulate throughput.
- Consumer Prefetch Limits - Implements QoS configuration to limit the number of in-flight unacknowledged messages.
- Request-Response Pattern Support - Implements synchronous request-response patterns for blocking calls during queue and exchange declarations.
- Message Queues and Brokers - Standard client for RabbitMQ messaging protocols.
