init rpc client once

2 years ago · 1428be637f
parent 558adb6863
commit 1428be637f
1 changed files with 2 additions and 2 deletions
--- a/internal/rpc/msg/server.go
+++ b/internal/rpc/msg/server.go
@ -77,8 +77,8 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e
 		MsgDatabase:            msgDatabase,
 		ExtendMsgDatabase:      extendMsgDatabase,
 		RegisterCenter:         client,
-		GroupLocalCache:        localcache.NewGroupLocalCache(client),
-		ConversationLocalCache: localcache.NewConversationLocalCache(client),
+		GroupLocalCache:        localcache.NewGroupLocalCache(&groupRpcClient),
+		ConversationLocalCache: localcache.NewConversationLocalCache(&conversationClient),
 		friend:                 &friendRpcClient,
 		MessageLocker:          NewLockerMessage(cacheModel),
 	}