Skip to content

Instantly share code, notes, and snippets.

@tobias
Created February 25, 2014 14:51
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tobias/39dabf64cb979b2e7022 to your computer and use it in GitHub Desktop.
Save tobias/39dabf64cb979b2e7022 to your computer and use it in GitHub Desktop.
; CIDER 0.5.0alpha (package: 20131212.641) (Clojure 1.5.1, nREPL 0.2.3)
user> (require '[immutant.messaging :as m])
nil
user> (m/start "topic")
nil
user> (m/listen "topic" println :concurrency 2)
#<util$waiting_derefable$reify__361@2839404e: #<MessageProcessorGroup org.immutant.messaging.MessageProcessorGroup@447b521f>>
user> (m/publish "topic" :hi)
#<HornetQTextMessage HornetQMessage[ID:4cae5604-9e2c-11e3-9457-7bc30fc5d058]:PERSISTENT>
user> :hi
:hi
user>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment