@asyncio.coroutine<EOL><INDENT>def purge(self):<DEDENT>
self.sender.send_QueuePurge(self.name)<EOL>yield from self.synchroniser.wait(spec.QueuePurgeOK)<EOL>self.reader.ready()<EOL>
Purge all undelivered messages from the queue.

This method is a :ref:`coroutine <coroutine>`.