修复实时查看
This commit is contained in:
parent
81e0c2a5bf
commit
9a234f50fb
|
|
@ -231,7 +231,7 @@ func GetRealTimeImage(c *gin.Context) {
|
||||||
|
|
||||||
func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) {
|
func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) {
|
||||||
ctx := context.Background()
|
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()
|
defer pubsub.Close()
|
||||||
ch := pubsub.Channel()
|
ch := pubsub.Channel()
|
||||||
var check_cnt int
|
var check_cnt int
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue