def test_iterconsume(self, n='test_iterconsume'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    c.close()
def test_iterconsume(self, n='test_iterconsume'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    c.close()