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 } }