hydromill-amqp 0.1a8

AMQP Pub/Sub for the Hydromill project. This project is a direct port of https://github.com/ThreeDotsLabs/watermill-amqp.

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

Watermill AMQP Pub/Sub

License

MIT License