allow consumer to define concurrency