diff --git a/internal/push/push_handler.go b/internal/push/push_handler.go index 37a04e893..fc5a00210 100644 --- a/internal/push/push_handler.go +++ b/internal/push/push_handler.go @@ -276,7 +276,7 @@ func (c *ConsumerHandler) asyncOfflinePush(ctx context.Context, needOfflinePushU if err := c.pushDatabase.MsgToOfflinePushMQ(ctx, conversationutil.GenConversationUniqueKeyForSingle(msg.SendID, msg.RecvID), needOfflinePushUserIDs, msg); err != nil { log.ZError(ctx, "Msg To OfflinePush MQ error", err, "needOfflinePushUserIDs", needOfflinePushUserIDs, "msg", msg) - // prommetrics.SingleChatMsgProcessFailedCounter.Inc() + prommetrics.SingleChatMsgProcessFailedCounter.Inc() return } }