From b3a2b4518fe6ac2f5fd7695edb29391e05d32e85 Mon Sep 17 00:00:00 2001 From: hujiebin Date: Fri, 1 Sep 2023 11:10:19 +0800 Subject: [PATCH] rediscluster queue --- domain/cache/gift_c/gift_event.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/domain/cache/gift_c/gift_event.go b/domain/cache/gift_c/gift_event.go index c671000..b53dcb8 100644 --- a/domain/cache/gift_c/gift_event.go +++ b/domain/cache/gift_c/gift_event.go @@ -14,7 +14,7 @@ const EventSendGiftHiloUserQueue = "send:gift:queue:hilo_user" func BLPopQueueSendGift(model *domain.Model) *gift_ev.SendGiftEvent { var res *gift_ev.SendGiftEvent queue := EventSendGiftHiloUserQueue - strs, err := model.Redis.BLPop(model, time.Second, queue).Result() + strs, err := model.RedisCluster.BLPop(model, time.Second, queue).Result() if err != nil { if err != redis.Nil { model.Log.Errorf("BLPopQueueSendGift fail:%v", err) -- 2.22.0