def METHOD_NAME(self, broker, message):
    """Called before a message is processed.
    Raises:
      SkipMessage: If the current message should be skipped.  When
        this is raised, ``after_skip_message`` is emitted instead
        of ``after_process_message``.
    """