W/o Durability
(ns activemq-sample (require io stomp)) (defn+ main () (let* (conn (stomp/connect "localhost" 61613 "" "") f (fn (msg) { (io/format "~p" [msg]) })) (stomp/subscribe "/topic/SampleTopic" conn) (stomp/on_message f conn) (stomp/disconnect conn) ) )
W/ Durability
(ns activemq-sample (require io stomp)) (defn+ main () (let* (conn (stomp/connect "localhost" 61613 "" "" [{"client-id", "SampleClient"}]) f (fn (msg) { (io/format "~p" [msg]) })) (stomp/subscribe "/topic/SampleTopic" conn [{"activemq.subscriptionName", "SampleSubscription"}]) (stomp/on_message f conn) (stomp/disconnect conn) ) )