code: def validate(self):
          
          for schema in (self.headers_schema, Message.headers_schema):
              _log.debug(
                  'Validating message headers "%r" with schema "%r"',
                  self._headers,
                  schema,
              )
              jsonschema.validate(self._headers, schema)
          for schema in (self.body_schema, Message.body_schema):
              _log.debug(
                  'Validating message body "%r" with schema "%r"', self.body, schema
              )
              jsonschema.validate(self.body, schema)
docs: Validate the headers and body with the message schema, if any.
  
          In addition to the user-provided schema, all messages are checked against
          the base schema which requires certain message headers and the that body
          be a JSON object.
  
          .. warning:: This method should not be overridden by sub-classes.
  
          Raises:
              jsonschema.ValidationError: If either the message headers or the message body
                  are invalid.
              jsonschema.SchemaError: If either the message header schema or the message body
                  schema are invalid.