"RIC_GNB_STATUS_INDICATION": C.RIC_GNB_STATUS_INDICATION,
"RIC_RESOURCE_STATUS_UPDATE": C.RIC_RESOURCE_STATUS_UPDATE,
"RIC_ERROR_INDICATION": C.RIC_ERROR_INDICATION,
+ "RIC_SGNB_ADDITION_REQ": C.RIC_SGNB_ADDITION_REQ,
+ "RIC_SGNB_ADDITION_ACK": C.RIC_SGNB_ADDITION_ACK,
+ "RIC_SGNB_ADDITION_REJECT": C.RIC_SGNB_ADDITION_REJECT,
+ "RIC_SGNB_RECONF_COMPLETE": C.RIC_SGNB_RECONF_COMPLETE,
+ "RIC_RRC_TRANSFER": C.RIC_RRC_TRANSFER,
"DC_ADM_INT_CONTROL": C.DC_ADM_INT_CONTROL,
"DC_ADM_INT_CONTROL_ACK": C.DC_ADM_INT_CONTROL_ACK,
}
RIC_GNB_STATUS_INDICATION = C.RIC_GNB_STATUS_INDICATION
RIC_RESOURCE_STATUS_UPDATE = C.RIC_RESOURCE_STATUS_UPDATE
RIC_ERROR_INDICATION = C.RIC_ERROR_INDICATION
+ RIC_SGNB_ADDITION_REQ = C.RIC_SGNB_ADDITION_REQ
+ RIC_SGNB_ADDITION_ACK = C.RIC_SGNB_ADDITION_ACK
+ RIC_SGNB_ADDITION_REJECT = C.RIC_SGNB_ADDITION_REJECT
+ RIC_SGNB_RECONF_COMPLETE = C.RIC_SGNB_RECONF_COMPLETE
+ RIC_RRC_TRANSFER = C.RIC_RRC_TRANSFER
DC_ADM_INT_CONTROL = C.DC_ADM_INT_CONTROL
DC_ADM_INT_CONTROL_ACK = C.DC_ADM_INT_CONTROL_ACK
)
RIC_GNB_STATUS_INDICATION: "RIC GNB STATUS INDICATION",
RIC_RESOURCE_STATUS_UPDATE: "RIC RESOURCE STATUS UPDATE",
RIC_ERROR_INDICATION: "RIC ERROR INDICATION",
+ RIC_SGNB_ADDITION_REQ: "RIC_SGNB_ADDITION_REQ",
+ RIC_SGNB_ADDITION_ACK: "RIC_SGNB_ADDITION_ACK",
+ RIC_SGNB_ADDITION_REJECT: "RIC_SGNB_ADDITION_REJECT",
+ RIC_SGNB_RECONF_COMPLETE: "RIC_SGNB_RECONF_COMPLETE",
+ RIC_RRC_TRANSFER: "RIC_RRC_TRANSFER",
DC_ADM_INT_CONTROL: "DC ADMISSION INTERVAL CONTROL",
DC_ADM_INT_CONTROL_ACK: "DC ADMISSION INTERVAL CONTROL ACK",
}
}
func (m Forwarder) Consume(params *xapp.RMRParams) (err error) {
- xapp.Logger.Debug("Message received - type=%d subId=%d meid=%v xid=%v", params.Mtype, params.SubId, params.Meid, params.Xid)
+ xapp.Logger.Debug("Message received - type=%d txid=%s subId=%d meid=%v",
+ params.Mtype, params.Xid, params.SubId, params.Meid)
// Store data and reply with the same message payload
if xapp.Config.GetInt("test.store") != 0 {
params.SubId = sid
}
- if ok := xapp.Rmr.SendMsg(params); !ok {
+ if ok := xapp.Rmr.SendRts(params); !ok {
xapp.Logger.Info("Rmr.Send failed ...")
}
return
}
func (m Generator) Consume(params *xapp.RMRParams) (err error) {
- xapp.Logger.Debug("message received - type=%d subId=%d meid=%v", params.Mtype, params.SubId, params.Meid)
+ xapp.Logger.Debug("message received - type=%d txid=%s ubId=%d meid=%v", params.Mtype, params.Xid, params.SubId, params.Meid)
mux.Lock()
rx++
params.SubId = subId
params.Payload = s
params.Meid = &xapp.RMRMeid{PlmnID: "123456", EnbID: "7788"}
- params.Xid = "TestXID"
+ params.Xid = "TestXID1234"
if ok := xapp.Rmr.SendMsg(params); ok {
tx++
if ack != 0 {