AMQP Pub/Sub for the Hydromill project. This project is a direct port of https://github.com/ThreeDotsLabs/watermill-amqp.
Project description
Hydromill AMQP Pub/Sub
AMQP Pub/Sub for the Hydromill project. This project is a direct port of Watermill AMQP Pub/Sub.
Usage
Example publisher:
amqp_uri = "amqp://guest:guest@localhost:5672/"
amqp_config = await new_durable_pubsub_config(amqp_uri)
publisher = await new_publisher(amqp_config)
message = Message(payload=b"simple")
await publisher.publish("topic", messages=[message])
References
License
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
hydromill_amqp-0.1a4.tar.gz
(4.6 kB
view hashes)
Built Distribution
Close
Hashes for hydromill_amqp-0.1a4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 435ba0d3a37a7cb59eabc3b0db137ff79d2fd571fa3873eb390136dacf95701d |
|
MD5 | 22139a7b55d0cd60cf9b9c75ff265bf8 |
|
BLAKE2b-256 | 02456478ef2d33e32ef68d4c6b9e784902e09d61d350c2119b49eed391d8b375 |