Commit e107c9c0 authored by iamhujiebin's avatar iamhujiebin

del

parent 7ea1556b
...@@ -122,6 +122,8 @@ func check() { ...@@ -122,6 +122,8 @@ func check() {
mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr) mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr)
} }
}() }()
n, err := redisCli.GetRedis().Del(context.Background(), SocketQueueSendGift).Result()
mylogrus.MyLog.Infof("del sendGiftChan msg queue:%v,n:%v,err:%v", SocketQueueSendGift, n, err)
} }
if l > 0 { if l > 0 {
mylogrus.MyLog.Infof("cron sendGiftChan msg,left %v", l) mylogrus.MyLog.Infof("cron sendGiftChan msg,left %v", l)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment