Add integration tests for queue consumer