Reactor - Clojure

core.clj

(ns reactor.clj.core
  (:import [reactor.core Reactor Context]))

;;create the reactor
(def reactor (Reactor. (Context/rootDispatcher)))
;;create the selector
(def selector (reactor.Fn/$ "print.received"))
;;create and implement the consumer
(def consumer (proxy [reactor.fn.Consumer][] (accept [event] (println "Received"))))

(defn -main
  "Prints Received"
  [& args]
  ;; attach consumer to the selector
  (.on reactor selector consumer)
  ;; notify!!
  (.notify reactor "print.received" (reactor.Fn/event nil)))