Skip to main content

basic/
basic.rs

1use devlogbus::{Client, ClientOptions};
2
3fn main() -> Result<(), Box<dyn std::error::Error>> {
4    let client = Client::new(ClientOptions {
5        source: Some("example_rust".to_string()),
6        ..Default::default()
7    });
8
9    client.publish_message(
10        "INFO",
11        "Rust worker started",
12        Some("{\"queue\":\"demo\"}".to_string()),
13    )?;
14    Ok(())
15}