W/o Durability
(def connFactory (new org.apache.activemq.ActiveMQConnectionFactory)) (def conn (.createConnection connFactory)) (def sess (.createSession conn false, javax.jms.Session/AUTO_ACKNOWLEDGE)) (def dest (.createTopic sess "SampleTopic")) (def cons (.createConsumer sess dest)) (.start conn) (def msg (.receive cons)) (println msg) (.close conn)
W/ Durability
(def connFactory (new org.apache.activemq.ActiveMQConnectionFactory)) (def conn (.createConnection connFactory)) (.setClientID conn "SampleClient") (def sess (.createSession conn false, javax.jms.Session/AUTO_ACKNOWLEDGE)) (def topic (.createTopic sess "SampleTopic")) (def cons (.createDurableSubscriber sess topic, "SampleSubscription")) (.start conn) (def msg (.receive cons)) (println msg) (.close conn)