def test_discard_all_filterfunc_not_supported(self, n='xjf21j21'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    with self.assertRaises(NotImplementedError):
        c.discard_all(filterfunc=(lambda x: x))
    c.close()
def test_discard_all_filterfunc_not_supported(self, n='xjf21j21'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    with self.assertRaises(NotImplementedError):
        c.discard_all(filterfunc=(lambda x: x))
    c.close()