def test_discard_all(self, n='test_discard_all'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    c.discard_all()
    self.assertIn('queue_purge', c.backend)
def test_discard_all(self, n='test_discard_all'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    c.discard_all()
    self.assertIn('queue_purge', c.backend)