diff --git a/main.py b/main.py
index 26c3419..1eb659c 100644
--- a/main.py
+++ b/main.py
@@ -340,6 +340,7 @@ def redis_message_handler():
                             "from": SERVICE_NAME,
                             "level": "content",
                             "to": user_id, 
+                            "ref": "catalog",
                             "content": result
                         }
                     }
@@ -541,7 +542,8 @@ def send_stream_notification(msg_type: str, content: any, batch_id: str, current
             "current_chunk": current_chunk,
             "total_chunks": total_chunks,
             "total_items": total_items,
-            "to": user_id, 
+            "to": user_id,
+            "ref": "catalog",
             "content": content
         }
     }
@@ -1638,6 +1640,7 @@ def handle_get_price(country: str, user_id: str, content: list):
                     "from": SERVICE_NAME,
                     "level": "content",
                     "to": user_id,
+                    "ref": "price",
                     "content": result
                 }
             }
@@ -1667,6 +1670,7 @@ def handle_get_price(country: str, user_id: str, content: list):
                     "from": SERVICE_NAME,
                     "level": "content",
                     "to": user_id,
+                    "ref": "price",
                     "content": {"error": str(e)}
                 }
             }