comp.clj

(defrecord ZmqRpc [zmq-rpc-url]
  component/Lifecycle
  (start [component]
    (let [ctx (ZMQ/context 1)
          worker-url "inproc://myapp-api-responders"
          router-socket (.socket ctx ZMQ/ROUTER)
          dealer-socket (.socket ctx ZMQ/DEALER)]
      (.bind router-socket zmq-rpc-url)
      (.bind dealer-socket worker-url)
      (dotimes [n 4]
        (doto (Thread. (zmq-rpc/create-rep-handler (:db component) ctx worker-url))
          (.setName (str "myapp-api-zmq-req-" n))
          (.start)))
      (doto (Thread. #(.run (ZMQQueue. ctx router-socket dealer-socket)))
        (.start))
      component))
  (stop [component]
    (doseq [thr (:zmq-rpc-worker-threads component)]
      (.interrupt thr))))