diff --git a/dtmcli/saga.go b/dtmcli/saga.go index b768d76..87cf08f 100644 --- a/dtmcli/saga.go +++ b/dtmcli/saga.go @@ -47,6 +47,7 @@ func (s *Saga) Submit() error { return dtmimp.TransCallDtm(&s.TransBase, s, "submit") } +// AddConcurrentContext adds concurrent options to the request context func (s *Saga) AddConcurrentContext() { if s.concurrent { s.CustomData = dtmimp.MustMarshalString(map[string]interface{}{"orders": s.orders, "concurrent": s.concurrent})