Clojure core.async-based interface to ZeroMQ.

Author: lynaghk

.gitignore

@@ -0,0 +1 @@
+target/

README.markdown

@@ -0,0 +1,12 @@
+# ZeroMQ Async
+
+ZeroMQ is a message-oriented socket system that supports many communication styles (request/response, publish/subscribe, fan-out, &c.) on top of many transport layers with bindings to many languages.
+This is a Clojure ZeroMQ interface built on core.async channels.
+
+## Quick start
+
+## Motivation
+
+ZeroMQ sockets are not thread safe.
+To support concurrent usage from Clojure, you need to spin up a dedicated thread to read/write from a socket and expose the socket to the rest of your system via, e.g., `java.util.concurrent` queues.
+This library does that behind the scenes for you so you don't have to think about it.

project.clj

@@ -0,0 +1,14 @@
+(defproject com.keminglabs/zmq-async "0.0.1-SNAPSHOT"
+  :description "ZeroMQ 3 library for Clojure"
+  :license {:name "BSD" :url "http://www.opensource.org/licenses/BSD-3-Clause"}
+
+  :min-lein-version "2.0.0"
+
+  :dependencies [[org.clojure/clojure "1.5.1"]
+                 [org.zeromq/jzmq "2.2.1-SNAPSHOT"]
+                 [core.async "0.1.0-SNAPSHOT"]]
+
+  :profiles {:dev {:source-paths ["dev"]
+                   :dependencies [[midje "1.5.1"]]}}
+
+  :jvm-opts ["-Djava.library.path=/usr/local/lib"])

src/zmq_async/core.clj

@@ -0,0 +1,13 @@
+(ns zmq-async.core
+  (:import (org.zeromq ZMQ ZMQ$Socket)))
+
+(def context
+  (ZMQ/context 1))
+
+(defn socket
+  [socket-type]
+  (.socket context (case socket-type
+                     :pull ZMQ/PULL
+                     :req ZMQ/REQ
+                     :rep ZMQ/REP
+                     :router ZMQ/ROUTER)))