Consumer endpoint now uses async.queue