user-ingest: Add debug statement

OpenSource-Deadlock-Tools · Oct 15, 2024 · babe6c6 · babe6c6
1 parent 43930bf
commit babe6c6
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/user-ingest/src/rmq.rs b/user-ingest/src/rmq.rs
@@ -29,7 +29,9 @@ pub async fn add_to_queue(routing_key: &str, body: &str) -> Result<(), ProcessEr
             BasicProperties::default(),
         )
         .await
-        .map(|_| ())
+        .map(|s| {
+            info!("Sent message to queue: {:?}", s);
+        })
         .map_err(ProcessError::RmqError)
 }
 
@@ -59,7 +61,7 @@ async fn get_rmq_channel() -> Result<&'static Channel, ProcessError> {
                 ),
                 ConnectionProperties::default(),
             )
-            .await
+                .await
         })
         .await
         .map_err(ProcessError::RmqError)?;
@@ -80,7 +82,7 @@ async fn get_rmq_public_channel() -> Result<&'static Channel, ProcessError> {
                 ),
                 ConnectionProperties::default(),
             )
-            .await
+                .await
         })
         .await
         .map_err(ProcessError::RmqError)?;