sparta-rabbit 0.0.8

Sparta rabbit library

sparta-rabbit

Sparta rabbit library.

Usage

import sparta.rabbit

conn_provider = sparta.rabbit.RabbitMQConnectionProvider(
    host="localhost",
    username="guest",
    password="guest",
    connection_name="some-identifier",  # this allows to identify the connection in RabbitMQ dashboard
)

client = sparta.rabbit.RabbitMQClient(conn_provider)
await client.create_queue("hello")
await client.publish_to_queue("hello", "hi there")
await client.listen_to_queue("hello", lambda message: print(f"Received {message}"), timeout=10)