diff --git a/internal/rpc/conversation/conversaion.go b/internal/rpc/conversation/conversaion.go index c15e3feaa..4649409b7 100644 --- a/internal/rpc/conversation/conversaion.go +++ b/internal/rpc/conversation/conversaion.go @@ -24,7 +24,7 @@ type conversationServer struct { groupRpcClient *rpcclient.GroupClient conversationDatabase controller.ConversationDatabase conversationNotificationSender *notification.ConversationNotificationSender - msgRpcClient rpcclient.MsgClient + msgRpcClient *rpcclient.MsgClient } func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error { @@ -43,7 +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), + msgRpcClient: rpcclient.NewMsgClient(client), conversationDatabase: controller.NewConversationDatabase(conversationDB, cache.NewConversationRedis(rdb, cache.GetDefaultOpt(), conversationDB), tx.NewGorm(db)), }) return nil