refactor: add error messages for Rabbit issues

2025-02-10 17:20:29 +00:00
parent fa55e88dd9
commit 439bacf067
1 changed files with 6 additions and 2 deletions
--- a/crates/delta/src/main.rs
+++ b/crates/delta/src/main.rs
@@ -89,8 +89,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(