chainmq 1.1.2

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, RedisClient, 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: RedisClient::Url("redis://127.0.0.1:6370".into()),
        ..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(())
}