From d63da9b7fd37f76e0c0b21b555d09d84050f42be Mon Sep 17 00:00:00 2001
From: luhaoling <2198702716@qq.com>
Date: Tue, 27 Feb 2024 16:57:19 +0800
Subject: [PATCH] fix: fix the param pass error

---
 internal/push/consumer_init.go | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/internal/push/consumer_init.go b/internal/push/consumer_init.go
index 6e6a2e898..673c9f6f4 100644
--- a/internal/push/consumer_init.go
+++ b/internal/push/consumer_init.go
@@ -17,8 +17,6 @@ package push
 import (
 	"context"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-
-	"github.com/OpenIMSDK/tools/log"
 )
 
 type Consumer struct {
@@ -37,9 +35,5 @@ func NewConsumer(config *config.GlobalConfig, pusher *Pusher) (*Consumer, error)
 }
 
 func (c *Consumer) Start() {
-	onError := func(ctx context.Context, err error, errInfo string) {
-		log.ZWarn(ctx, errInfo, err)
-	}
-	go c.pushCh.pushConsumerGroup.RegisterHandleAndConsumer(context.Background(), &c.pushCh, onError)
-
+	go c.pushCh.pushConsumerGroup.RegisterHandleAndConsumer(context.Background(), &c.pushCh)
 }