diff --git a/domain/cache/gift_c/gift_event.go b/domain/cache/gift_c/gift_event.go index c6710004b1df5690f1b6064ac5444004d0288c08..b53dcb8f5482b540dd48db7cdebec6d962b1b648 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)