listener.clj

(require '[com.keminglabs.zmq-async.core :refer [register-socket!]]
         '[clojure.core.async :refer [>! <! <!! >!! go chan sliding-buffer close!]])

(let [addr "tcp://*:9999"
      [s-in s-out] (repeatedly 2 #(chan (sliding-buffer 64)))]

  (register-socket! {:in s-in :out s-out :socket-type :rep
                     :configurator (fn [socket] (.bind socket addr))})

  (println "waiting messages...")
    (while true
      (println (String. (<!! s-out)))
      (go (>! s-in "OK"))))

sender.clj

(require '[com.keminglabs.zmq-async.core :refer [register-socket!]]
         '[clojure.core.async :refer [>! <! <!! >!! go chan sliding-buffer close!]])

(let [addr "tcp://localhost:9999"
      [s-in s-out] (repeatedly 2 #(chan (sliding-buffer 64)))]

  (register-socket! {:in s-in :out s-out :socket-type :req
                     :configurator (fn [socket] (.connect socket addr))})

  (println "type to send..")
  (while true
    (>!! s-in (read-line))
    (go (println (String. (<! s-out))))))