code: def reject_message(self, delivery_tag, requeue=False, **kwargs):
          
          logger.info('Rejecting message', delivery_tag=delivery_tag, **kwargs)
          self._channel.basic_reject(delivery_tag, requeue=requeue)
docs: Reject the message delivery from RabbitMQ by sending a
          Basic.Reject RPC method for the delivery tag.
          :param int delivery_tag: The delivery tag from the Basic.Deliver frame