-func (m Consumer) Consume(mtype, sid int, payload []byte, meid *RMRMeid) (err error) {
- Sdl.Store("myKey", payload)
+func (m Consumer) Consume(params *RMRParams) (err error) {
+ //Logger.Info("Message received - type=%d subId=%d meid=%v xid=%s src=%s", params.Mtype, params.SubId, params.Meid.RanName, params.Xid, params.Src)
+ Sdl.Store("myKey", params.Payload)