fix: removed match

raphael-goetz · raphael-goetz · commit ad0fe855619d · 2025-04-19T17:29:56.000+02:00
diff --git a/src/flow_queue/service.rs b/src/flow_queue/service.rs
@@ -267,13 +267,10 @@ impl RabbitmqClient {
             }
 
             // Acknowledge the message
-            match delivery
+            delivery
                 .ack(lapin::options::BasicAckOptions::default())
                 .await
-            {
-                Ok(_) => Ok(()),
-                Err(err) => log::error!("Failed to acknowledge message: {}", err),
-            }
+                .expect("Failed to acknowledge message");
         }
 
         Ok(())

Original file line number	Diff line number	Diff line change
`@@ -267,13 +267,10 @@ impl RabbitmqClient {`
`267`	`267`	`}`
`268`	`268`
`269`	`269`	`// Acknowledge the message`
`270`		`- match delivery`
	`270`	`+ delivery`
`271`	`271`	`.ack(lapin::options::BasicAckOptions::default())`
`272`	`272`	`.await`
`273`		`- {`
`274`		`- Ok(_) => Ok(()),`
`275`		`- Err(err) => log::error!("Failed to acknowledge message: {}", err),`
`276`		`- }`
	`273`	`+ .expect("Failed to acknowledge message");`
`277`	`274`	`}`
`278`	`275`
`279`	`276`	`Ok(())`