From 817686754375742b60fbb3a1463f43db961de069 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 adeff3737..84b7f8af3 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" @@ -86,7 +87,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 ctx := ctx wg.Go(func() error {