better

Author: sanderegg

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

@@ -36,12 +36,11 @@ async def create(
         return client
 
     async def _rpc_initialize(self) -> None:
-        url = f"{self.settings.dsn}?name={get_rabbitmq_client_unique_name(self.client_name)}&heartbeat={self.heartbeat}"
+        connection_name = f"{get_rabbitmq_client_unique_name(self.client_name)}.rpc"
+        url = f"{self.settings.dsn}?name={connection_name}"
         self._connection = await aio_pika.connect_robust(
             url,
-            client_properties={
-                "connection_name": f"{get_rabbitmq_client_unique_name(self.client_name)}.rpc"
-            },
+            client_properties={"connection_name": connection_name},
         )
         self._channel = await self._connection.channel()