Browse Source

registerTccBranch and registerXaBranch changed to registerBranch

pull/85/head
yedf2 4 years ago
parent
commit
c480d06606
  1. 2
      dtmcli/tcc.go
  2. 2
      dtmcli/xa.go
  3. 2
      test/tcc_barrier_test.go

2
dtmcli/tcc.go

@ -65,7 +65,7 @@ func (t *Tcc) CallBranch(body interface{}, tryURL string, confirmURL string, can
"branch_id": branchID,
BranchConfirm: confirmURL,
BranchCancel: cancelURL,
}, "registerTccBranch")
}, "registerBranch")
if err != nil {
return nil, err
}

2
dtmcli/xa.go

@ -77,7 +77,7 @@ func (xc *XaClient) XaLocalTransaction(qs url.Values, xaFunc XaLocalFunc) error
return dtmimp.TransRegisterBranch(&xa.TransBase, map[string]string{
"url": xc.XaClientBase.NotifyURL,
"branch_id": xa.BranchID,
}, "registerXaBranch")
}, "registerBranch")
})
}

2
test/tcc_barrier_test.go

@ -83,7 +83,7 @@ func TestTccBarrierDisorder(t *testing.T) {
"data": string(dtmimp.MustMarshal(body)),
dtmcli.BranchConfirm: confirmURL,
dtmcli.BranchCancel: cancelURL,
}).Post(fmt.Sprintf("%s/%s", tcc.Dtm, "registerTccBranch"))
}).Post(fmt.Sprintf("%s/%s", tcc.Dtm, "registerBranch"))
assert.Nil(t, err)
assert.Contains(t, resp.String(), dtmcli.ResultSuccess)

Loading…
Cancel
Save