init

2 years ago · a2f3d11110
parent 97c08e982b
commit a2f3d11110
1 changed files with 1 additions and 0 deletions
--- a/internal/rpc/conversation/conversaion.go
+++ b/internal/rpc/conversation/conversaion.go
@ -43,6 +43,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e
 	pbConversation.RegisterConversationServer(server, &conversationServer{
 		conversationNotificationSender: notification.NewConversationNotificationSender(client),
 		groupRpcClient:                 rpcclient.NewGroupClient(client),
+		msgRpcClient:                   *rpcclient.NewMsgClient(client),
 		conversationDatabase:           controller.NewConversationDatabase(conversationDB, cache.NewConversationRedis(rdb, cache.GetDefaultOpt(), conversationDB), tx.NewGorm(db)),
 	})
 	return nil