From f6acda0203960bcf398e74f229fd49be527f480f Mon Sep 17 00:00:00 2001 From: icey-yu <1186114839@qq.com> Date: Mon, 12 Aug 2024 18:19:05 +0800 Subject: [PATCH] fix: del return --- internal/push/push_handler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/push/push_handler.go b/internal/push/push_handler.go index 26241ee2e..9ee91e404 100644 --- a/internal/push/push_handler.go +++ b/internal/push/push_handler.go @@ -91,9 +91,9 @@ func (c *ConsumerHandler) handleMs2PsChat(ctx context.Context, msg []byte) { } sec := msgFromMQ.MsgData.SendTime / 1000 nowSec := timeutil.GetCurrentTimestampBySecond() + if nowSec-sec > 10 { log.ZWarn(ctx, "ignore push msg", nil, "msg", pbData.String(), "sec", sec, "nowSec", nowSec, "nowSec-sec", nowSec-sec) - return } var err error switch msgFromMQ.MsgData.SessionType {