W/o Durability
module com.wordpress.simplesassim.activemq import javax.jms.Session import org.apache.activemq.ActiveMQConnectionFactory function main = |args| { let connFactory = ActiveMQConnectionFactory() let conn = connFactory: createConnection() let sess = conn: createSession(false, Session.AUTO_ACKNOWLEDGE()) let dest = sess: createTopic("SampleTopic") let cons = sess: createConsumer(dest) conn: start() let msg = cons: receive() println(msg) conn: close() }
W/ Durability
module com.wordpress.simplesassim.activemq import javax.jms.Session import org.apache.activemq.ActiveMQConnectionFactory function main = |args| { let connFactory = ActiveMQConnectionFactory() let conn = connFactory: createConnection() conn: setClientID("SampleClient") let sess = conn: createSession(false, Session.AUTO_ACKNOWLEDGE()) let dest = sess: createTopic("SampleTopic") let cons = sess: createDurableSubscriber(dest, "SampleSubscription") conn: start() let msg = cons: receive() println(msg) conn: close() }
Leave a comment