feat: local cache

2 years ago · 4a042489bf
parent 9e4a7d082d
commit 4a042489bf
1 changed files with 2 additions and 2 deletions
--- a/internal/push/push_rpc_server.go
+++ b/internal/push/push_rpc_server.go
@ -51,8 +51,8 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e
 		client,
 		offlinePusher,
 		database,
-		rpccache.NewGroupLocalCache(rpcclient.NewGroupRpcClient(client), rdb),
-		rpccache.NewConversationLocalCache(rpcclient.NewConversationRpcClient(client), rdb),
+		rpccache.NewGroupLocalCache(groupRpcClient, rdb),
+		rpccache.NewConversationLocalCache(conversationRpcClient, rdb),
 		&conversationRpcClient,
 		&groupRpcClient,
 		&msgRpcClient,