fail.clj

(defprotocol Connected
  (connected? [_])
  (get-connection [_]))

(defn listener [afn space thing]
  (let [conn-atom (atom nil)]
    (proxy [elephantdb.common.kryo.Connected Listener] []
      (connected? [_] (boolean @conn-atom))

      (get-connection [_]
        @conn-atom)

      (connected [conn]
        (reset! conn-atom conn)
        (.addConnection space thing))

      (received [conn obj]
        (when-not (instance? FrameworkMessage obj)
          (afn conn obj))))))