Added integration test that tests both consume and consume async