Skip to main content

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

pre-commit Imports: isort Code style: black Poetry

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

Watermill AMQP Pub/Sub

License

MIT License

Project details


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.1a8.tar.gz (5.0 kB view hashes)

Uploaded Source

Built Distribution

hydromill_amqp-0.1a8-py3-none-any.whl (6.6 kB view hashes)

Uploaded Python 3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page