diff --git a/crates/delta/src/main.rs b/crates/delta/src/main.rs index aaa76932..ae7556ce 100644 --- a/crates/delta/src/main.rs +++ b/crates/delta/src/main.rs @@ -93,8 +93,12 @@ pub async fn web() -> Rocket { &config.rabbit.password, )) .await - .unwrap(); - let channel = connection.open_channel(None).await.unwrap(); + .expect("Failed to connect to RabbitMQ"); + + let channel = connection + .open_channel(None) + .await + .expect("Failed to open RabbitMQ channel"); channel .exchange_declare(