diff --git a/examples/grpc_saga.go b/examples/grpc_saga.go index 395976b..eb2c6b0 100644 --- a/examples/grpc_saga.go +++ b/examples/grpc_saga.go @@ -17,7 +17,7 @@ func init() { gid := dtmgrpc.MustGenGid(DtmGrpcServer) saga := dtmgrpc.NewSagaGrpc(DtmGrpcServer, gid). Add(BusiGrpc+"/examples.Busi/TransOut", BusiGrpc+"/examples.Busi/TransOutRevert", req). - Add(BusiGrpc+"/examples.Busi/TransIn", BusiGrpc+"/examples.Busi/TransOutRevert", req) + Add(BusiGrpc+"/examples.Busi/TransIn", BusiGrpc+"/examples.Busi/TransInRevert", req) err := saga.Submit() logger.FatalIfError(err) return saga.Gid @@ -27,7 +27,7 @@ func init() { gid := dtmgrpc.MustGenGid(DtmGrpcServer) saga := dtmgrpc.NewSagaGrpc(DtmGrpcServer, gid). Add(BusiGrpc+"/examples.Busi/TransOut", BusiGrpc+"/examples.Busi/TransOutRevert", req). - Add(BusiGrpc+"/examples.Busi/TransIn", BusiGrpc+"/examples.Busi/TransOutRevert", req) + Add(BusiGrpc+"/examples.Busi/TransIn", BusiGrpc+"/examples.Busi/TransInRevert", req) saga.WaitResult = true err := saga.Submit() logger.FatalIfError(err)