From 9a234f50fb1dc426e85a0028d30bfbbe3cbc1c9a Mon Sep 17 00:00:00 2001 From: junleea <354425203@qq.com> Date: Mon, 28 Oct 2024 21:01:23 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=AE=9E=E6=97=B6=E6=9F=A5?= =?UTF-8?q?=E7=9C=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- handler/device.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/handler/device.go b/handler/device.go index a0030aa..5ea231f 100644 --- a/handler/device.go +++ b/handler/device.go @@ -231,7 +231,7 @@ func GetRealTimeImage(c *gin.Context) { func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) { ctx := context.Background() - pubsub := worker.RedisClient.Subscribe(ctx, strconv.Itoa(device_id)+"_frames_channel") + pubsub := worker.RedisClient.Subscribe(ctx, strconv.Itoa(device_id)+"_frames_msgs") defer pubsub.Close() ch := pubsub.Channel() var check_cnt int