We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent de9b15a commit 45a55feCopy full SHA for 45a55fe
packages/service-library/src/servicelib/rabbitmq/_client_rpc.py
@@ -36,6 +36,9 @@ async def create(
36
return client
37
38
async def _rpc_initialize(self) -> None:
39
+ # NOTE: to show the connection name in the rabbitMQ UI see there
40
+ # https://www.bountysource.com/issues/89342433-setting-custom-connection-name-via-client_properties-doesn-t-work-when-connecting-using-an-amqp-url
41
+ #
42
connection_name = f"{get_rabbitmq_client_unique_name(self.client_name)}.rpc"
43
url = f"{self.settings.dsn}?name={connection_name}"
44
self._connection = await aio_pika.connect_robust(
0 commit comments