From 428dfbf07919ed6cd6493b1cf3db6643e47f7f07 Mon Sep 17 00:00:00 2001
From: dspeck1 <dspeck@burwood.com>
Date: Mon, 23 Dec 2024 14:55:05 -0600
Subject: [PATCH] Set stream name.

---
 src/main.py | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/main.py b/src/main.py
index 9bfdd45..64b9eb8 100644
--- a/src/main.py
+++ b/src/main.py
@@ -101,11 +101,10 @@ def detector_load(conf: dict, instrument: str) -> list[int]:
 
 async def fan_out_msg(
     redis_client,
-    fan_out_topic,
     data
 ):
     logging.info(f"sending msg {data}")
-    await redis_client.xadd(fan_out_topic, data)
+    await redis_client.xadd("instrument:lsstcomcamsim", data)
 
 async def main() -> None:
 
@@ -433,7 +432,6 @@ async def main() -> None:
 
                                 fan_out_msg(
                                     redis_client,
-                                    fan_out_topic,
                                     fan_out_message
                                 )
                             )