Metadata-Version: 2.4
Name: kombu-asyncio
Version: 6.0.0a3
Summary: Pure asyncio messaging library for Python
Project-URL: Source, https://github.com/oliverhaas/kombu-asyncio
Author-email: Oliver Haas <ohaas@e1plus.de>
License-Expression: BSD-3-Clause
License-File: LICENSE
Keywords: async,asyncio,celery,messaging,python,queue,redis,valkey
Classifier: Development Status :: 3 - Alpha
Classifier: Framework :: AsyncIO
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: BSD License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3.14
Classifier: Programming Language :: Python :: Implementation :: CPython
Classifier: Topic :: Communications
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Classifier: Topic :: System :: Distributed Computing
Classifier: Topic :: System :: Networking
Classifier: Typing :: Typed
Requires-Python: >=3.14
Provides-Extra: amqp
Requires-Dist: aio-pika>=9.0.0; extra == 'amqp'
Provides-Extra: msgpack
Requires-Dist: msgpack; extra == 'msgpack'
Provides-Extra: redis
Requires-Dist: redis>=7.1.0; extra == 'redis'
Provides-Extra: valkey
Requires-Dist: valkey>=6.1.0; extra == 'valkey'
Provides-Extra: yaml
Requires-Dist: pyyaml>=3.10; extra == 'yaml'
Description-Content-Type: text/markdown

# kombu-asyncio

Asyncio-native rewrite of [Kombu](https://github.com/celery/kombu), the well-established messaging library behind [Celery](https://github.com/celery/celery). This is the messaging layer for [celery-asyncio](https://github.com/oliverhaas/celery-asyncio).

This project is **exploratory**. It is not affiliated with or endorsed by the Celery project. If you're looking for the official production-ready messaging library, use the original [Kombu](https://github.com/celery/kombu) with our without [Celery](https://github.com/celery/celery).

This package exists as a standalone library for compatibility with packages that import from `kombu` directly (e.g. Celery Flower). Long-term it will probably be merged into celery-asyncio.

## Overview

- Ground-up asyncio rewrite, all operations are `async`/`await`, no sync API
- Transports: Valkey/Redis, AMQP (via aio-pika), Memory, Filesystem
- Exchange types: direct, fanout, topic (emulated on Valkey/Redis)
- **Not a drop-in replacement for Kombu**, this is a completely breaking change from the original

## Key differences from Kombu

| Kombu | kombu-asyncio |
|-------|---------------|
| `with Connection() as conn:` | `async with Connection() as conn:` |
| `conn.drain_events()` | `await conn.drain_events()` |
| `producer.publish(...)` | `await producer.publish(...)` |
| `message.ack()` | `await message.ack()` |
| Sync + async API | Async only |

## Requirements

- Python 3.14+
- valkey-py 6.1+ or redis-py 7.1+ (Valkey/Redis transport)
- aio-pika 9+ (AMQP transport, optional)

## License

BSD-3-Clause (same as Kombu)
