W/o Durability
(import "javax.jms.Session") (import "org.apache.activemq.ActiveMQConnectionFactory") (define connFactory (ActiveMQConnectionFactory.)) (define conn (.createConnection connFactory)) (define sess (.createSession conn #f Session.AUTO_ACKNOWLEDGE$)) (define dest (.createTopic sess "SampleTopic")) (define consumer (.createConsumer sess dest)) (.start conn) (define msg (.receive consumer)) (display msg) (.close conn)
W/ Durability
(import "javax.jms.Session") (import "org.apache.activemq.ActiveMQConnectionFactory") (define connFactory (ActiveMQConnectionFactory.)) (define conn (.createConnection connFactory)) (.setClientID conn "SampleClient") (define sess (.createSession conn #f Session.AUTO_ACKNOWLEDGE$)) (define topic (.createTopic sess "SampleTopic")) (define consumer (.createDurableSubscriber sess topic "SampleSubscription")) (.start conn) (define msg (.receive consumer)) (display msg) (.close conn)