X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fregistry.go;fp=pkg%2Fcontrol%2Fregistry.go;h=396daded93335e834879b7442a2f6a0f0786e5d5;hb=cc7d9e0cf982acb7448e23e8c8d16b9aaaf133fb;hp=5e16c0aadf0f894cd8296dec37788068feb34e28;hpb=3a0694199c3d4d1830a1833b04fbfc09eb5be1ae;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/registry.go b/pkg/control/registry.go index 5e16c0a..396dade 100644 --- a/pkg/control/registry.go +++ b/pkg/control/registry.go @@ -142,6 +142,8 @@ func (r *Registry) AssignToSubscription(trans *TransactionXapp, subReqMsg *e2ap. if actionType == e2ap.E2AP_ActionTypePolicy { if subs, ok := r.register[trans.GetSubId()]; ok { xapp.Logger.Debug("CREATE %s. Existing subscription for Policy found", subs.String()) + // Update message data to subscription + subs.SubReqMsg = subReqMsg subs.SetCachedResponse(nil, true) return subs, nil }