@synchronized('lock')
    def queue_purge(self, queue='', nowait=False):
        args = AMQPWriter()
        args.write_short(0)
        args.write_shortstr(queue)
        args.write_bit(nowait)
        self._send_method(Method(spec.Queue.Purge, args))

        if not nowait:
            return self.wait(spec.Queue.PurgeOk)
Purge a queue
dataset/ETHPy150Open veegee/amqpy/amqpy/channel.py/Channel.queue_purge