Fix

Author: Anton3

rabbitmq/functional_tests/basic_chaos/rabbitmq_service.cpp

@@ -33,7 +33,7 @@ class ChaosProducer final : public components::LoggableComponentBase {
 
         auto admin_channel = rabbit_client_->GetAdminChannel(setup_deadline);
         admin_channel.DeclareExchange(exchange_, urabbitmq::Exchange::Type::kFanOut, setup_deadline);
-        admin_channel.DeclareQueue(queue_, urabbitmq::Queue::Flags::kExclusive, setup_deadline);
+        admin_channel.DeclareQueue(queue_, urabbitmq::Queue::Flags::kDurable, setup_deadline);
         admin_channel.BindQueue(exchange_, queue_, routing_key_, setup_deadline);
     }
 

rabbitmq/functional_tests/metrics/rabbitmq_service.cpp

@@ -34,7 +34,7 @@ class MyRabbitProducer final : public components::LoggableComponentBase {
 
         auto admin_channel = client_->GetAdminChannel(setup_deadline);
         admin_channel.DeclareExchange(exchange_, urabbitmq::Exchange::Type::kFanOut, setup_deadline);
-        admin_channel.DeclareQueue(queue_, urabbitmq::Queue::Flags::kExclusive, setup_deadline);
+        admin_channel.DeclareQueue(queue_, urabbitmq::Queue::Flags::kDurable, setup_deadline);
         admin_channel.BindQueue(exchange_, queue_, routing_key_, setup_deadline);
     }
 

rabbitmq/src/tests/admin_rmqtest.cpp

@@ -42,7 +42,7 @@ UTEST(AdminChannel, DeclareRemoveQueue) {
 
     auto new_channel = client->GetAdminChannel(client.GetDeadline());
     new_channel.RemoveQueue(queue, client.GetDeadline());
-    declare_queue(new_channel, urabbitmq::Queue::Flags::kNone);
+    declare_queue(new_channel, urabbitmq::Queue::Flags::kAutoDelete);
     new_channel.RemoveQueue(queue, client.GetDeadline());
 }
 

rabbitmq/src/tests/publish_consume_rmqtest.cpp

@@ -246,7 +246,7 @@ UTEST(Consumer, ForDifferentQueuesWork) {
     const urabbitmq::Queue second_queue{utils::generators::GenerateUuid()};
     {
         auto channel = client->GetAdminChannel(client.GetDeadline());
-        channel.DeclareQueue(second_queue, urabbitmq::Queue::Flags::kExclusive, client.GetDeadline());
+        channel.DeclareQueue(second_queue, urabbitmq::Queue::Flags::kAutoDelete, client.GetDeadline());
         channel.BindQueue(client.GetExchange(), second_queue, client.GetRoutingKey(), client.GetDeadline());
     }
 

rabbitmq/src/tests/utils_rmqtest.cpp

@@ -67,7 +67,7 @@ engine::Deadline ClientWrapper::GetDeadline() const { return deadline_; }
 
 void ClientWrapper::SetupRmqEntities() const {
     admin_.DeclareExchange(GetExchange(), urabbitmq::Exchange::Type::kFanOut, {}, GetDeadline());
-    admin_.DeclareQueue(GetQueue(), urabbitmq::Queue::Flags::kExclusive, GetDeadline());
+    admin_.DeclareQueue(GetQueue(), urabbitmq::Queue::Flags::kAutoDelete, GetDeadline());
     admin_.BindQueue(GetExchange(), GetQueue(), GetRoutingKey(), GetDeadline());
 }
 

samples/rabbitmq_service/main.cpp

@@ -34,7 +34,7 @@ class MyRabbitProducer final : public components::LoggableComponentBase {
 
         auto admin_channel = client_->GetAdminChannel(setup_deadline);
         admin_channel.DeclareExchange(exchange_, urabbitmq::Exchange::Type::kFanOut, setup_deadline);
-        admin_channel.DeclareQueue(queue_, urabbitmq::Queue::Flags::kExclusive, setup_deadline);
+        admin_channel.DeclareQueue(queue_, urabbitmq::Queue::Flags::kDurable, setup_deadline);
         admin_channel.BindQueue(exchange_, queue_, routing_key_, setup_deadline);
     }