fix: 暂时取消 mq 消息处理，仅处理rpc

app/user_center/rpc/user_center.go

@@ -1,11 +1,8 @@
 package main
 
 import (
-	"context"
 	"flag"
 	"fmt"
-	"live-service/app/user_center/rpc/msg_transfer"
-
 	"live-service/app/user_center/rpc/internal/config"
 	"live-service/app/user_center/rpc/internal/server"
 	"live-service/app/user_center/rpc/internal/svc"
@@ -29,8 +26,8 @@ func main() {
 	svr := server.NewUserCenterServer(ctx)
 
 	// msg_transfer
-	msg_transfer.Init(context.Background(), ctx, svr)
+	//msg_transfer.Init(context.Background(), ctx, svr)
-	msg_transfer.Run()
+	//msg_transfer.Run()
 
 	s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
 		pb.RegisterUserCenterServer(grpcServer, svr)