Skip to content

Instantly share code, notes, and snippets.

@lispnik
Created May 27, 2013 20:46
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 lispnik/5658993 to your computer and use it in GitHub Desktop.
Save lispnik/5658993 to your computer and use it in GitHub Desktop.
standalone.xml:
...
<jms-destinations>
<jms-queue name="queue/test">
<entry name="java:/queue/test"/>
<durable>true</durable>
</jms-queue>
</jms-destinations>
</hornetq-server>
(app1) immutant.init.clj:
(immutant.messaging/publish "queue/test" "test!") => #<HornetQTextMessage HornetQMessage[ID:c91ced8e-c70b-11e2-bab3-13561a84739e]:PERSISTENT>
(app2 same vm) immutant.init.clj:
(immutant.messaging/listen "queue/test" #'println) => IllegalStateException queue/test is not available org.immutant.messaging.MessageProcessorGroupizer.createGroup (MessageProcessorGroupizer.java:61)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment