import (
"fmt"
- "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
"sync"
)
t.transactionXappTable = make(map[TransactionXappKey]*Transaction)
}
-func (t *Tracker) TrackTransaction(subs *Subscription, endpoint RmrEndpoint, params *xapp.RMRParams, respReceived bool, forwardRespToXapp bool) (*Transaction, error) {
+func (t *Tracker) TrackTransaction(endpoint RmrEndpoint, params *RMRParams, respReceived bool, forwardRespToXapp bool) (*Transaction, error) {
trans := &Transaction{
tracker: nil,
Subs: nil,
RmrEndpoint: endpoint,
+ Mtype: params.Mtype,
Xid: params.Xid,
OrigParams: params,
RespReceived: respReceived,
return nil, err
}
- err := subs.SetTransaction(trans)
- if err != nil {
- return nil, err
- }
trans.tracker = t
t.transactionXappTable[xappkey] = trans
return trans, nil