Refactor the entire system to be the queue worker/writer