* Once job_count is reached, stop jobs from being consumed
* Unit tests for above change in consume.t