refactor: add error messages for Rabbit issues

2025-02-10 17:20:29 +00:00
parent a4246f39e4
commit 343b90b9af
1 changed files with 6 additions and 2 deletions
--- a/crates/delta/src/main.rs
+++ b/crates/delta/src/main.rs
@@ -93,8 +93,12 @@ pub async fn web() -> Rocket<Build> {
        &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(