Metadata-Version: 2.4
Name: rmqaio
Version: 0.17.1
Summary: Async RabbitMQ library with spec-based API, topology restore, and automatic reconnection
License: MIT
License-File: LICENSE
Keywords: rabbitmq
Author: Roman Koshel
Author-email: roma.koshel@gmail.com
Requires-Python: >=3.10,<4.0
Classifier: Development Status :: 3 - Alpha
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Programming Language :: Python :: 3.14
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Classifier: Topic :: Utilities
Requires-Dist: aiormq (>=6.7.6)
Requires-Dist: yarl
Description-Content-Type: text/markdown

# RMQaio

Async RabbitMQ library with spec-based API, topology restore, and automatic reconnection.

## Installation

```bash
pip install rmqaio
```

## Quick Start

```python
import asyncio
from rmqaio import Connection, Exchange, ExchangeSpec, Ops, Queue, QueueSpec

async def main():
    conn = Connection("amqp://localhost")
    await conn.open()

    ops = Ops(conn)

    exchange = Exchange(ExchangeSpec(name="events", type="topic", durable=True), ops)
    await exchange.declare(restore=True)

    queue = Queue(QueueSpec(name="my-queue", durable=True), ops)
    await queue.declare(restore=True)
    await queue.bind("events", routing_key="#", restore=True)

    await conn.close()

asyncio.run(main())
```

[Documentation](https://levsh.github.io/rmqaio)

