Changed queue.concurrency to a getter/setter so that process() is called when concurrency increases