remove queue name

Author: matusdrobuliak66

packages/service-library/src/servicelib/rabbitmq/_client.py

@@ -151,7 +151,6 @@ async def subscribe(
         message_ttl: NonNegativeInt = RABBIT_QUEUE_MESSAGE_DEFAULT_TTL_MS,
         unexpected_error_retry_delay_s: float = _DEFAULT_UNEXPECTED_ERROR_RETRY_DELAY_S,
         unexpected_error_max_attempts: int = _DEFAULT_UNEXPECTED_ERROR_MAX_ATTEMPTS,
-        queue_name: str | None = None,
     ) -> str:
         """subscribe to exchange_name calling ``message_handler`` for every incoming message
         - exclusive_queue: True means that every instance of this application will
@@ -217,7 +216,6 @@ async def subscribe(
                 exclusive_queue=exclusive_queue,
                 message_ttl=message_ttl,
                 arguments={"x-dead-letter-exchange": delayed_exchange_name},
-                queue_name=queue_name,
             )
             if topics is None:
                 await queue.bind(exchange, routing_key="")
@@ -237,7 +235,6 @@ async def subscribe(
                 exclusive_queue=exclusive_queue,
                 message_ttl=int(unexpected_error_retry_delay_s * 1000),
                 arguments={"x-dead-letter-exchange": exchange.name},
-                queue_name=queue_name,
             )
             await delayed_queue.bind(delayed_exchange)
 

packages/service-library/src/servicelib/rabbitmq/_utils.py

@@ -70,7 +70,6 @@ async def declare_queue(
     exclusive_queue: bool,
     arguments: dict[str, Any] | None = None,
     message_ttl: NonNegativeInt = RABBIT_QUEUE_MESSAGE_DEFAULT_TTL_MS,
-    queue_name: str | None = None,
 ) -> aio_pika.abc.AbstractRobustQueue:
     default_arguments = {"x-message-ttl": message_ttl}
     if arguments is not None:
@@ -83,7 +82,7 @@ async def declare_queue(
     }
     if not exclusive_queue:
         # NOTE: setting a name will ensure multiple instance will take their data here
-        queue_parameters |= {"name": queue_name if queue_name else exchange_name}
+        queue_parameters |= {"name": exchange_name}
 
     # NOTE: if below line raises something similar to ``ChannelPreconditionFailed: PRECONDITION_FAILED``
     # most likely someone changed the signature of the queues (parameters etc...)

services/efs-guardian/src/simcore_service_efs_guardian/services/process_messages_setup.py

@@ -28,7 +28,6 @@ async def _subscribe_to_rabbitmq(app) -> str:
             ),
             exclusive_queue=False,
             message_ttl=_RUT_MESSAGE_TTL_IN_MS,
-            queue_name="efs-dynamic-service-running-queue",
         )
         return subscribed_queue