You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@servicecomb.apache.org by "Willem Jiang (JIRA)" <ji...@apache.org> on 2018/11/15 06:43:00 UTC

[jira] [Reopened] (SCB-785) Cannot get the GlobalTxId and LocalTxId in the compensation method

     [ https://issues.apache.org/jira/browse/SCB-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Willem Jiang reopened SCB-785:
------------------------------
      Assignee: Willem Jiang  (was: Jeremy Xu)

> Cannot get the GlobalTxId and LocalTxId in the compensation method
> ------------------------------------------------------------------
>
>                 Key: SCB-785
>                 URL: https://issues.apache.org/jira/browse/SCB-785
>             Project: Apache ServiceComb
>          Issue Type: Improvement
>          Components: Saga
>    Affects Versions: saga-0.2.0
>            Reporter: Jeremy Xu
>            Assignee: Willem Jiang
>            Priority: Minor
>             Fix For: saga-0.3.0, saga-0.2.1
>
>
> 补偿方法里无法获取分布式事务的全局事务ID及本地事务ID
> 因为在子事务业务处理方法中会将一部分中间数据存入外部缓存中,对应的补偿方法将可以通过这些中间数据进行合理的补偿操作,当时存入中间数据时会附带上globalTxId, localTxId,后面将根据这个查找到之前存入的中间数据。但发现在业务方法中可以获取分布式事务的全局事务ID及本地事务ID,但对应的补偿方法里却不行。
> Customer may want to access the globalTxId and LocalTxId in application to store these information into DB for the recovery. 
> 示例代码如下:
>  
> {code:java}
> @Autowired
> OmegaContext omegaContext;
> @Compensable(timeout=5, compensationMethod="cancel")
> public boolean transferOut(String from, int amount) {
>   // 这里可以获得
>   System.out.println(omegaContext.globalTxId());
>   System.out.println(omegaContext.localTxId());
>   repo.reduceBalanceByUsername(from, amount);
> }
> public boolean cancel(String from, int amount) {
>   // 这里不可以获得
>   System.out.println(omegaContext.globalTxId());
>   System.out.println(omegaContext.localTxId());
>   repo.addBalanceByUsername(from, amount);
> }
> {code}
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)