From c2862424f21ca4aced3ddeaa25e108f614b1d463 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Mon, 20 Mar 2023 10:44:22 +0800 Subject: [PATCH] msg update --- internal/push/consumer_init.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/internal/push/consumer_init.go b/internal/push/consumer_init.go index cead76bbf..6eba5306e 100644 --- a/internal/push/consumer_init.go +++ b/internal/push/consumer_init.go @@ -7,11 +7,7 @@ package push import ( - "fmt" - "github.com/OpenIMSDK/Open-IM-Server/pkg/common/config" - "github.com/OpenIMSDK/Open-IM-Server/pkg/common/constant" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/prome" - "github.com/OpenIMSDK/Open-IM-Server/pkg/statistics" ) type Consumer struct { @@ -31,6 +27,6 @@ func (c *Consumer) initPrometheus() { } func (c *Consumer) Start() { - statistics.NewStatistics(&c.successCount, config.Config.ModuleName.PushName, fmt.Sprintf("%d second push to msg_gateway count", constant.StatisticsTimeInterval), constant.StatisticsTimeInterval) + //statistics.NewStatistics(&c.successCount, config.Config.ModuleName.PushName, fmt.Sprintf("%d second push to msg_gateway count", constant.StatisticsTimeInterval), constant.StatisticsTimeInterval) go c.pushCh.pushConsumerGroup.RegisterHandleAndConsumer(&c.pushCh) }