blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-03 01:52:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: push msg

Browse Source
This commit is contained in:
icey-yu 2024-09-02 19:54:02 +08:00
parent ba3333e9ef
commit c03abf2f60
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/push/push_handler.go
View File

@ -94,7 +94,7 @@ func (c *ConsumerHandler) handleMs2PsChat(ctx context.Context, msg []byte) {
if nowSec-sec > 10 { if nowSec-sec > 10 {
prommetrics.MsgLoneTimePushCounter.Inc() prommetrics.MsgLoneTimePushCounter.Inc()
log.ZWarn(ctx, "It’s been a while since the message was sent, so the receiver can’t get it now.", nil, "msg", pbData.String(), "sec", sec, "nowSec", nowSec, "nowSec-sec", nowSec-sec) log.ZWarn(ctx, "it’s been a while since the message was sent", nil, "msg", pbData.String(), "sec", sec, "nowSec", nowSec, "nowSec-sec", nowSec-sec)
} }
var err error var err error
switch msgFromMQ.MsgData.SessionType { switch msgFromMQ.MsgData.SessionType {