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.1a6.tar.gz
(4.8 kB
view hashes)
Built Distribution
Close
Hashes for hydromill_amqp-0.1a6-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 43d01a678db4e44f5b42a254e952b2a2034544212ac4807b9d5fe384ee26f6bd |
|
MD5 | 9c590b0994b5bf72635051b877e99bfa |
|
BLAKE2b-256 | e0f2551cd6ccb5a725b24d471b885c0f43c6f5eeca4af17dbb32901d6c0415d7 |