def test_process_next(self, n='test_process_next'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    with self.assertRaises(NotImplementedError):
        c.process_next()
    c.close()
def test_process_next(self, n='test_process_next'):
    c = compat.Consumer(self.connection, queue=n, exchange=n, routing_key='rkey')
    with self.assertRaises(NotImplementedError):
        c.process_next()
    c.close()