Skip to content

Commit 09acabc

Browse files
committed
fix client naming
1 parent 02c182d commit 09acabc

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,12 +32,13 @@ async def create(
3232
cls, *, client_name: str, settings: RabbitSettings, **kwargs
3333
) -> "RabbitMQRPCClient":
3434
client = cls(client_name=client_name, settings=settings, **kwargs)
35-
await client._rpc_initialize() # noqa: SLF001
35+
await client._rpc_initialize()
3636
return client
3737

3838
async def _rpc_initialize(self) -> None:
39+
url = f"{self.settings.dsn}?name={get_rabbitmq_client_unique_name(self.client_name)}&heartbeat={self.heartbeat}"
3940
self._connection = await aio_pika.connect_robust(
40-
self.settings.dsn,
41+
url,
4142
client_properties={
4243
"connection_name": f"{get_rabbitmq_client_unique_name(self.client_name)}.rpc"
4344
},

0 commit comments

Comments
 (0)