shuttle-bus-rabbitmq 0.0.1

No project description provided

Shuttle Bus

A modern distributed application framework for Python.

Build Status

Branch	Status
master
develop

Getting started

Install

pip install shuttle-bus-rabbitmq

Simple example

uri = "amqp://admin:admin@localhost/"
host_settings = HostSettings.create(uri)

receive_settings = ReceiveSettings()
receive_settings.name = "queue_name"

consumer = PrintConsumer()
receive_endpoint_configuration = ReceiveEndpointConfiguration(receive_settings, consumer)

bus_configuration = BusConfiguration(host_settings)

bus = await Bus.create(bus_configuration, receive_endpoint_configuration)

await bus.start()
await bus.publish(bytes("Hello", "UTF-8"))
await bus.stop()

Versioning

Shuttle Bus follows Semantic Versioning.

Contributing

See CONTRIBUTING.md

Builds

See https://pypi.org/project/shuttle-bus/

Requirements

• Python >= 3.6

Credits

• aio-pika