+         try:

+             message = message.get('body', message)

+             log.debug('Processing message "%s"', message)

+             with self.flask_app.app_context():

+                 self._consume_message(message)

+         except Exception:  # pylint: disable=broad-except

+             # Disallow propagating any other exception, otherwise NACK is sent

+             # and the message is scheduled to be received later. But it seems

+             # these messages can be only received by other consumer (or after

+             # restart) otherwise the messages can block the queue completely.

+             log.exception('Unexpected exception')