Merge pull request #1149 from nerdvegas/issue_1148-pika-conn-name

Issue 1148 pika conn name
AcademySoftwareFoundation · Nov 2, 2021 · d93ea7a · d93ea7a
2 parents d6e522f + c96dabf
commit d93ea7a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/src/rez/utils/_version.py b/src/rez/utils/_version.py
@@ -1,7 +1,7 @@
 
 
 # Update this value to version up Rez. Do not place anything else in this file.
-_rez_version = "2.97.0"
+_rez_version = "2.98.0"
 
 
 # Copyright 2013-2016 Allan Johns.

diff --git a/src/rez/utils/amqp.py b/src/rez/utils/amqp.py
@@ -67,6 +67,11 @@ def _publish_message(host, amqp_settings, routing_key, data):
 
     conn_kwargs = dict()
 
+    # name the conn like 'rez.publish.{host}'
+    conn_kwargs["client_properties"] = {
+        "connection_name": "rez.publish.%s" % socket.gethostname()
+    }
+
     host, port = parse_host_and_port(url=host)
     conn_kwargs["host"] = host
     if port is not None: