code: def _consume_errback(failure):
      
      global _exit_code
      if failure.check(exceptions.BadDeclaration):
          _log.error(
              "Unable to declare the %s object on the AMQP broker. The "
              "broker responded with %s. Check permissions for your user.",
              failure.value.obj_type,
              failure.value.reason,
          )
          _exit_code = 10
      elif failure.check(exceptions.PermissionException):
          _exit_code = 15
          _log.error(
              "The consumer could not proceed because of a permissions problem: %s",
              str(failure.value),
          )
      elif failure.check(exceptions.ConnectionException):
          _exit_code = 14
          _log.error(failure.value.reason)
      else:
          _exit_code = 11
          _log.exception(
              "An unexpected error (%r) occurred while registering the "
              "consumer, please report this bug.",
              failure.value,
          )
      try:
          reactor.stop()
      except error.ReactorNotRunning:
          pass
docs: Handle any errors that occur during consumer registration.