From 700b72518241013e1287dadef089e7634b26ca45 Mon Sep 17 00:00:00 2001 From: Monet Lee Date: Mon, 9 Sep 2024 15:54:18 +0800 Subject: [PATCH] add PushMQ log. --- internal/push/push_handler.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/push/push_handler.go b/internal/push/push_handler.go index bf0fb649d..b478185ba 100644 --- a/internal/push/push_handler.go +++ b/internal/push/push_handler.go @@ -273,7 +273,9 @@ func (c *ConsumerHandler) asyncOfflinePush(ctx context.Context, needOfflinePushU needOfflinePushUserIDs = offlinePushUserIDs } if err := c.pushDatabase.MsgToOfflinePushMQ(ctx, conversationutil.GenConversationUniqueKeyForSingle(msg.SendID, msg.RecvID), needOfflinePushUserIDs, msg); err != nil { - prommetrics.SingleChatMsgProcessFailedCounter.Inc() + log.ZError(ctx, "Msg To OfflinePush MQ error", err, "needOfflinePushUserIDs", + needOfflinePushUserIDs, "msg", msg) + // prommetrics.SingleChatMsgProcessFailedCounter.Inc() return } }