docs: def reject(self, message, requeue=True):
          """Reject the message on the broker and log it.
  
          :param message: The message to reject
          :type message: rejected.Data.message
          :param bool requeue: Specify if the message should be re-queued or not
  
          """
          if self.no_ack:
              raise RuntimeError('Can not rejected messages when ack is False')
  
          if message.channel.is_closed:
              LOGGER.warning('Can not nack message, disconnected from RabbitMQ')
              self.counters[self.CLOSED_ON_COMPLETE] += 1
              return
  
          LOGGER.warning('Rejecting message %s %s requeue', message.delivery_tag,
                         'with' if requeue else 'without')
          message.channel.basic_nack(
              delivery_tag=message.delivery_tag, requeue=requeue)
          self.measurement.set_tag(self.NACKED, True)
          self.measurement.set_tag(self.REQUEUED, requeue)