jacobemcken

(ns immutant.init
  (:require [clj-time.core :as dt]
            [immutant.messaging :as msg]))

(msg/start "/queue/a-queue")
(msg/listen "/queue/a-queue" #(println "received: " %))

(msg/publish "/queue/a-queue" {:created (dt/now)}) ; gives a stacktrace