From 274e51ccab5c18fcf5d36019015729b1d5364b1e Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Mon, 13 May 2024 15:07:40 +0800 Subject: [PATCH] Add etcd as a service discovery mechanism --- internal/push/onlinepusher.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/push/onlinepusher.go b/internal/push/onlinepusher.go index 74e3e5306..ddc500806 100644 --- a/internal/push/onlinepusher.go +++ b/internal/push/onlinepusher.go @@ -2,6 +2,7 @@ package push import ( "context" + "fmt" "github.com/openimsdk/protocol/msggateway" "github.com/openimsdk/protocol/sdkws" "github.com/openimsdk/tools/discovery" @@ -81,7 +82,8 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M // Online push message for _, conn := range conns { - log.ZDebug(ctx, "get gateway conn detail ", "conn ", *conn) + fmt.Println(ctx, "get gateway conn detail ", "conn ", *conn) + conn := conn // loop var safe wg.Go(func() error { msgClient := msggateway.NewMsgGatewayClient(conn)