Browse Source
Merge pull request #126 from slw2011/liwei.song/hotfix/fix-grpc-saga-typo
Fix grpc_saga typo
pull/128/head
yedf2
4 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
2 additions and
2 deletions
-
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) |
|
|
|
|