def reject(self, requeue=True):
        if not self._method:
            raise AMQPMessageError('Message.reject only available on '
                                   'incoming messages')
        self._channel.basic.reject(delivery_tag=self._method['delivery_tag'],
                                   requeue=requeue)
Reject Message.
dataset/ETHPy150Open eandersson/amqpstorm/amqpstorm/message.py/Message.reject