code: def make_message(self, data):
  
          
  
          data = self.codec.loads(data)
          msg = Message(
              data.get("data"),
              *data.get("args",[]),
              **data.get("kwargs",{})
          )
          msg.meta.update(data.get("meta"))
          self.trigger("make_message", data, msg)
          return msg
docs: Create a Message instance from data, data will be loaded
          via munge according to the codec specified in the
          transport_content_type attribute
  
          Returns:
  
              Message: message object