qrusty_client

A Rust client for the qrusty priority queue server API.

Features

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

Installation

Add to your Cargo.toml:

[dependencies]
qrusty_client = "0.2"

Usage

use qrusty_client::Client;

#[tokio::main]
async fn main() {
    let client = Client::new("http://localhost:6784");
    client.publish("orders", 100, "{\"order_id\":123}", 3).await.unwrap();
    let msg = client.consume("orders", "worker-1", 30).await.unwrap();
    client.ack("orders", &msg.id, "worker-1").await.unwrap();
}

Development

Don't forget your crates.io token if you intend to publish the crate.

docker login <your-token>

Documentation

See docs.rs/qrusty_client for full API documentation.

License

MIT