W/o Durability
import org.apache.activemq.ActiveMQConnectionFactory import javax.jms.Session final object ActiveMQSample { def main(args: Array[String]) { val connFactory = new ActiveMQConnectionFactory() val conn = connFactory.createConnection() val sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE) val dest = sess.createTopic("SampleTopic") val cons = sess.createConsumer(dest) conn.start() val msg = cons.receive() println(msg) conn.close() } }
W/ Durability
import org.apache.activemq.ActiveMQConnectionFactory import javax.jms.Session final object ActiveMQSample { def main(args: Array[String]) { val connFactory = new ActiveMQConnectionFactory() val conn = connFactory.createConnection() conn.setClientID("SampleClient") val sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE) val dest = sess.createTopic("SampleTopic") val cons = sess.createDurableSubscriber(dest, "SampleSubscription") conn.start() val msg = cons.receive() println(msg) conn.close() } }