jobQueue = new JobQueue consumers, limit, period

jobQueue.addConsumers consumers, limit, period

jobQueue.enqueue job

pendingJobs = jobQueue.pendingJobs

JobQueue = require "job-queue"
 
makeConsumer = (consumerId) ->
    (job) ->
        console.log "Consumer #{consumerId} processing job #{job.id}"
        job.process consumerId
 
# Create a process queue with 5 consumers where each supports up to 5 requests per second 
processQueue = new JobQueue [1..5].map(makeConsumer), 5, 1000
 
# Add another 5 consumers to the process queue where each supports up to 80 jobs per minute 
processQueue.addConsumers [6..10].map(makeConsumer), 80, 60 * 1000
 
# Adding 10k jobs to the process queue 
for jobId in [1..10000] then do (jobId) ->
    processQueue.enqueue
        id: jobId
        process: (consumerId) ->
            # The rate limited section (e.g. some API call) 
            console.log "Job #{jobId} processed by consumer #{consumerId}"