From e2a47daaf4d9e212c4b5bc6a980e033ef35162cd Mon Sep 17 00:00:00 2001
From: Bread White <32078281+breadrock1@users.noreply.github.com>
Date: Mon, 25 Nov 2024 15:01:32 +0300
Subject: [PATCH] Fix/fix (#13)

* fix(compose): docker compose fixes

* chore(rmq): replaced direct to fanout exchange kind

* chore(ci): fixed fmt and clippy warnigns

---------

Co-authored-by: Bread White <breadrock1@email.net>
---
 src/publish/rabbit/mod.rs | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/publish/rabbit/mod.rs b/src/publish/rabbit/mod.rs
index 613e100..b73affb 100644
--- a/src/publish/rabbit/mod.rs
+++ b/src/publish/rabbit/mod.rs
@@ -37,8 +37,8 @@ impl ServiceConnect for RabbitPublisher {
         let channel = connection.create_channel().await?;
 
         let exchange_opts = ExchangeDeclareOptions {
-            nowait: true,
-            durable: false,
+            nowait: config.no_wait(),
+            durable: config.durable(),
             ..Default::default()
         };
 
@@ -86,9 +86,10 @@ impl Publisher for RabbitPublisher {
             .await?;
 
         tracing::info!(
-            exchange = exchange,
-            routing_key = routing,
-            "rabbit confirm: {confirm:?}"
+            exchange=exchange,
+            routing=routing,
+            confirm=?confirm,
+            "rabbit confirmed"
         );
 
         Ok(())