🐛 rabbitmq queue name prefix is unique during the lifecycle of the container

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

@@ -1,8 +1,10 @@
 import logging
+import os
 import socket
 from typing import Any, Final
 
 import aio_pika
+import psutil
 from aiormq.exceptions import ChannelPreconditionFailed
 from pydantic import NonNegativeInt
 from tenacity import retry
@@ -51,7 +53,13 @@ async def wait_till_rabbitmq_responsive(url: str) -> bool:
 
 
 def get_rabbitmq_client_unique_name(base_name: str) -> str:
-    return f"{base_name}_{socket.gethostname()}"
+    # NOTE: below prefix is guaranteed to change each time the preocess restarts
+    # Why is this desiarable?
+    # 1. the code base makes the above assumption, otherwise subcscribers and consumers do not work
+    # 2. enables restartability of webserver during [re]deploys
+    prefix_create_time = f"{psutil.Process(os.getpid()).create_time()}".strip(".")[-6:]
+
+    return f"{base_name}_{socket.gethostname()}_{prefix_create_time}"
 
 
 async def declare_queue(