From 439bacf067fd886b4cba2be96a4db8d3510b4dd3 Mon Sep 17 00:00:00 2001 From: Paul Makles Date: Mon, 10 Feb 2025 17:20:29 +0000 Subject: [PATCH] refactor: add error messages for Rabbit issues --- crates/delta/src/main.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/crates/delta/src/main.rs b/crates/delta/src/main.rs index c25cf7fa..0561a9da 100644 --- a/crates/delta/src/main.rs +++ b/crates/delta/src/main.rs @@ -89,8 +89,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(