chainmq 1.0.0

A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

// examples/start_ui.rs
// Example showing how to start the web UI automatically with a custom path

use chainmq::{Queue, QueueOptions, WebUIConfig, start_web_ui};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Initialize logging
    tracing_subscriber::fmt::try_init().ok();

    // Create queue with your Redis connection
    let options = QueueOptions {
        redis_url: "redis://127.0.0.1:6370".to_string(),
        ..Default::default()
    };
    let queue = Queue::new(options).await?;

    // Configure the web UI
    let ui_config = WebUIConfig {
        port: 8080,
        ui_path: "/dashboard".to_string(),
        ..Default::default()
    };

    println!("Starting ChainMQ Web UI...");
    println!(
        "Access the dashboard at: http://127.0.0.1:{}{}",
        ui_config.port, ui_config.ui_path
    );

    // Start the web UI server
    // This will run until the process is terminated
    start_web_ui(queue, ui_config).await?.await?;

    Ok(())
}