-func (m Forwarder) Consume(mtype, subId, len int, payload []byte) (err error) {
- xapp.Logger.Debug("Message received - type=%d subId=%d len=%d", mtype, subId, len)
+func (m Forwarder) Consume(mtype, subId int, payload []byte, meid *xapp.RMRMeid) (err error) {
+ xapp.Logger.Debug("Message received - type=%d subId=%d meid=%v", mtype, subId, meid)