qrusty-pyclient 0.19.4

Python client wrapper for the qrusty API.

qrusty_pyclient

A Python client wrapper for the qrusty API.

Features

• Connect to a qrusty server
• Publish, consume, ack, and purge messages
• List and manage queues

Installation

pip install qrusty_pyclient

Usage

from qrusty_pyclient import QrustyClient

client = QrustyClient(base_url="http://localhost:6784")
client.create_queue(name="orders", ordering="MaxFirst", allow_duplicates=True)
client.publish(queue="orders", priority=100, payload={"order_id": 123})

# Text priorities are also supported for queues with priority_kind="Text"
client.create_queue(name="tags", ordering="MinFirst", priority_kind="Text")
client.publish(queue="tags", priority="alpha", payload={"tag": "first"})
message = client.consume(queue="orders", consumer_id="worker-1")
if message is not None:
    client.ack(queue="orders", message_id=message["id"], consumer_id="worker-1")

Development

Don't forget your ~/.pypirc file if you intend to publish to PyPI.

License

MIT