Commit37e4945

authored

Bugfix xa not throw (#72)

* public xa constructor* Adjust XaGlobalTransaction Excecute function signatures* throw XaGlobalTransaction ExecuteAsync Exception

1 parentfe25d97 commit37e4945Copy full SHA for 37e4945

File tree

-4

lines changed

-4

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -14,15 +14,15 @@ public sealed class Xa : TransBase`
`14`	`14`	`{`
`15`	`15`	`privatereadonlyIDtmClient_dtmClient;`
`16`	`16`
`17`		`-internalXa(IDtmClientdtmHttpClient,stringgid)`
	`17`	`+publicXa(IDtmClientdtmHttpClient,stringgid)`
`18`	`18`	`{`
`19`	`19`	`this._dtmClient=dtmHttpClient;`
`20`	`20`	`this.Gid=gid;`
`21`	`21`	`this.TransType=DtmCommon.Constant.TYPE_XA;`
`22`	`22`	`this.BranchIDGen=newBranchIDGen();`
`23`	`23`	`}`
`24`	`24`
`25`		`-internalXa(IDtmClientdtmHttpClient)`
	`25`	`+publicXa(IDtmClientdtmHttpClient)`
`26`	`26`	`{`
`27`	`27`	`this._dtmClient=dtmHttpClient;`
`28`	`28`	`}`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -20,11 +20,11 @@ public XaGlobalTransaction(IDtmClient dtmClient, ILoggerFactory factory)`
`20`	`20`	`publicasyncTask<string>ExcecuteAsync(Func<Xa,Task>xa_cb,CancellationTokencancellationToken=default)`
`21`	`21`	`{`
`22`	`22`	`vargid=await_dtmClient.GenGid(cancellationToken);`
`23`		`-awaitthis.Excecute(gid,xa_cb,cancellationToken);`
	`23`	`+awaitthis.ExcecuteAsync(gid,xa_cb,cancellationToken);`
`24`	`24`	`returngid;`
`25`	`25`	`}`
`26`	`26`
`27`		`-publicasyncTaskExcecute(stringgid,Func<Xa,Task>xa_cb,CancellationTokencancellationToken=default)`
	`27`	`+publicasyncTaskExcecuteAsync(stringgid,Func<Xa,Task>xa_cb,CancellationTokencancellationToken=default)`
`28`	`28`	`{`
`29`	`29`	`awaitExcecuteAsync(gid,null,xa_cb,cancellationToken);`
`30`	`30`	`}`
`@@ -46,6 +46,7 @@ public async Task ExcecuteAsync(string gid, Action<Xa> custom, Func<Xa, Task> xa`
`46`	`46`	`xa.RollbackReason=ex.Message.Substring(0,ex.Message.Length>1023?1023:ex.Message.Length);`
`47`	`47`	`_logger.LogError(ex,"prepare or submitting global transaction error");`
`48`	`48`	`await_dtmClient.TransCallDtm(null,xa,Constant.Request.OPERATION_ABORT,cancellationToken);`
	`49`	`+throw;`
`49`	`50`	`}`
`50`	`51`	`}`
`51`	`52`	`}`

Comments

(0)