a1.Logger.Error("error : %v", err)
return err
}
- isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1PolicyRequest)
+ isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1PolicyRequest, int(policyTypeId))
if isSent {
a1.Logger.Debug("rmrSendToXapp : message sent")
} else {
a1.Logger.Error("error : %v", err1)
return err1
}
- isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1PolicyRequest)
+ isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1PolicyRequest, int(policyTypeId))
if isSent {
a1.Logger.Debug("rmrSendToXapp : message sent")
} else {
return err
}
a1.Logger.Debug("rmrSendToXapp :rmrMessage %+v", rmrMessage)
- isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1EIDataDelivery)
+ isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1EIDataDelivery, rmr.DefaultSubId)
if isSent {
a1.Logger.Debug("rmrSendToXapp : message sent")
} else {
a1.Logger.Debug("metadatainstancekey : %+v", metadatainstancekey)
metadatainstancearr := []interface{}{metadatainstancekey, string(metadata)}
sdlInst.On("Set", "A1m_ns", metadatainstancearr).Return(nil)
- rmrSenderInst.On("RmrSendToXapp", "httpBodyString", 20010).Return(true)
+ rmrSenderInst.On("RmrSendToXapp", "httpBodyString", 20010, int(policyTypeId)).Return(true)
errresp := rh.CreatePolicyInstance(policyTypeId, policyInstanceID, instancedata)
httpBodyString := `{"operation":"DELETE","payload":"","policy_instance_id":"123456","policy_type_id":"20001"}`
- rmrSenderInst.On("RmrSendToXapp", httpBodyString, 20010).Return(true)
+ rmrSenderInst.On("RmrSendToXapp", httpBodyString, 20010, int(policyTypeId)).Return(true)
errresp := rh.DeletePolicyInstance(policyTypeId, policyInstanceID)
json.Unmarshal([]byte(httpBody), &instancedata)
a1.Logger.Debug("Marshaled data : %+v", (instancedata))
httpBodyString := `{"ei_job_id":"1","payload":"payload"}`
- rmrSenderInst.On("RmrSendToXapp", httpBodyString, 20017).Return(true)
+ rmrSenderInst.On("RmrSendToXapp", httpBodyString, 20017, -1).Return(true)
errresp := rh.DataDelivery(instancedata)
assert.Nil(t, errresp)
return args.Bool(0), args.Error(1)
}
-func (rmr *RmrSenderMock) RmrSendToXapp(httpBodyString string, mtype int) bool {
+func (rmr *RmrSenderMock) RmrSendToXapp(httpBodyString string, mtype int, subid int) bool {
if httpBodyString == `{"blocking_rate":20,"enforce":true,"trigger_threshold":10,"window_length":20}` {
- args := rmr.MethodCalled("RmrSendToXapp", httpBodyString, mtype)
+ args := rmr.MethodCalled("RmrSendToXapp", httpBodyString, mtype, subid)
return args.Bool(0)
} else if httpBodyString == `{"ei_job_id":"1","payload":"payload"}` {
- args := rmr.MethodCalled("RmrSendToXapp", httpBodyString, mtype)
+ args := rmr.MethodCalled("RmrSendToXapp", httpBodyString, mtype, subid)
return args.Bool(0)
}
return true
a1EiQueryAllResp = 20014
a1EiCreateJobResp = 20016
jobCreationData = `{"ei_job_id": %s.}`
+ DefaultSubId = -1
)
type RmrSender struct {
}
type IRmrSender interface {
- RmrSendToXapp(httpBodyString string, messagetype int) bool
+ RmrSendToXapp(httpBodyString string, messagetype int, subid int) bool
}
func NewRMRSender(policyManager *policy.PolicyManager) IRmrSender {
return
}
-func (rmr *RmrSender) RmrSendToXapp(httpBodyString string, messagetype int) bool {
+func (rmr *RmrSender) RmrSendToXapp(httpBodyString string, messagetype int, subid int) bool {
params := &xapp.RMRParams{}
params.Mtype = messagetype
- params.SubId = -1
+ params.SubId = subid
params.Xid = ""
params.Meid = &xapp.RMRMeid{}
params.Src = a1SourceName
return err1
}
a1.Logger.Debug("rmrMessage ", rmrMessage)
- isSent := rmr.RmrSendToXapp(rmrMessage, a1PolicyRequest)
+ isSent := rmr.RmrSendToXapp(rmrMessage, a1PolicyRequest, int(policytypeid))
if isSent {
a1.Logger.Debug("rmrSendToXapp : message sent")
} else {
a1.Logger.Debug("response : %+v", string(respByte))
- isSent := rmr.RmrSendToXapp(string(respByte), a1EiQueryAllResp)
+ isSent := rmr.RmrSendToXapp(string(respByte), a1EiQueryAllResp, DefaultSubId)
if isSent {
a1.Logger.Debug("rmrSendToXapp : message sent")
} else {
rmrData := fmt.Sprintf(jobCreationData, jobIdStr)
a1.Logger.Debug("rmr_Data to send: ", rmrData)
- isSent := rmr.RmrSendToXapp(rmrData, a1EiCreateJobResp)
+ isSent := rmr.RmrSendToXapp(rmrData, a1EiCreateJobResp, DefaultSubId)
if isSent {
a1.Logger.Debug("rmrSendToXapp : message sent")
} else {