Refactor pub/sub, user clojure atom instead of redis