Skip to content

Instantly share code, notes, and snippets.

@ebaxt

ebaxt/pipe.clj

Forked from pingles/pipe.clj
Last active December 10, 2015 23:29
Show Gist options
  • Save ebaxt/4510065 to your computer and use it in GitHub Desktop.
Save ebaxt/4510065 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
pipe.clj
(let [[message-seq put] (pipe)]
(letfn [(message-handler [ch msg-meta payload]
(put {:ch ch :msg-meta msg-meta :payload payload}))]
(lc/subscribe ch qname message-handler :auto-ack true))
message-seq)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment