def queue_purge(self, queue=''):
        with _CallbackResult(self._MethodFrameCallbackResultArgs) as \
                purge_ok_result:
            self._impl.queue_purge(callback=purge_ok_result.set_value_once,
                                   queue=queue,
                                   nowait=False)

            self._flush_output(purge_ok_result.is_ready)
            return purge_ok_result.value.method_frame
Purge all of the messages from the specified queue
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel.queue_purge