diff --git a/internal/push/push_rpc_server.go b/internal/push/push_rpc_server.go index 9da1eaaf5..08ab12563 100644 --- a/internal/push/push_rpc_server.go +++ b/internal/push/push_rpc_server.go @@ -9,6 +9,7 @@ import ( "github.com/OpenIMSDK/Open-IM-Server/pkg/discoveryregistry" pbPush "github.com/OpenIMSDK/Open-IM-Server/pkg/proto/push" "google.golang.org/grpc" + "google.golang.org/grpc/credentials/insecure" "sync" ) @@ -22,7 +23,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e return err } cacheModel := cache.NewCacheModel(rdb) - + client.AddOption(grpc.WithTransportCredentials(insecure.NewCredentials())) offlinePusher := NewOfflinePusher(cacheModel) database := controller.NewPushDatabase(cacheModel) pusher := NewPusher(client, offlinePusher, database, localcache.NewGroupLocalCache(client), localcache.NewConversationLocalCache(client)) diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go index 62d5d4728..72eb6547a 100644 --- a/internal/push/push_to_client.go +++ b/internal/push/push_to_client.go @@ -185,7 +185,7 @@ func (p *Pusher) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, msgClient := msggateway.NewMsgGatewayClient(v) reply, err := msgClient.SuperGroupOnlineBatchPushOneMsg(ctx, &msggateway.OnlineBatchPushOneMsgReq{MsgData: msg, PushToUserIDs: pushToUserIDs}) if err != nil { - log.NewError(mcontext.GetOperationID(ctx), msg, len(pushToUserIDs), "err", err) + continue } if reply != nil && reply.SinglePushResult != nil {