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