gistfile1.txt

(ns immutant.init
  (:require [immutant.messaging :as msg]
            [immutant.pipeline :as pl]
            [clojure.tools.logging :as log]))


(defn add-two [m]
  (log/info "add-two processing" m)
  (+ 2 m))

(defn times-three [m]
  (log/info "times-three processing" m)
  (* 3 m))

(defonce test-pipeline
  (pl/pipeline "test"
               add-two
               times-three))

(def t "/topic/test")

(msg/start t)

(msg/listen t #(log/info "got" %))
(msg/listen t #(log/spyf :info "processed: %d" (deref (test-pipeline %))))