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