Sparta rabbit library
Project description
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)
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
sparta-rabbit-0.0.7.tar.gz
(6.0 kB
view hashes)
Built Distribution
Close
Hashes for sparta_rabbit-0.0.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 51f8c9ed9345416a65ace5b54769f5479c77fd698fb02a13b496e590bf781855 |
|
MD5 | d602877c6444f296e201262c6a6da399 |
|
BLAKE2b-256 | 2a12cd25196be44acbea1547219ce5d99d15473bdb92a884c7d402e024f5e35c |