func (t *Tracker) NewSubsTransaction(subs *Subscription) *TransactionSubs {
trans := &TransactionSubs{}
trans.Meid = subs.GetMeid()
- rid := subs.GetReqId()
- if rid != nil {
- trans.ReqId = *rid
- }
t.initTransaction(&trans.Transaction)
xapp.Logger.Debug("CREATE %s", trans.String())
return trans
}
func (t *Tracker) NewXappTransaction(
- endpoint *RmrEndpoint,
+ endpoint *xapp.RmrEndpoint,
xid string,
- reqId *RequestId,
+ subid uint32,
meid *xapp.RMRMeid) *TransactionXapp {
trans := &TransactionXapp{}
trans.XappKey = &TransactionXappKey{*endpoint, xid}
trans.Meid = meid
- if reqId != nil {
- trans.ReqId = *reqId
- }
+ trans.SubId = subid
t.initTransaction(&trans.Transaction)
xapp.Logger.Debug("CREATE %s", trans.String())
return trans