W/o Durability
import(java.lang.System) import(javax.jms.Session) import(org.apache.activemq.ActiveMQConnectionFactory) connFactory <- ActiveMQConnectionFactory$new() conn <- connFactory$createConnection() sess <- conn$createSession(FALSE, Session$AUTO_ACKNOWLEDGE) dest <- sess$createTopic("SampleTopic") cons <- sess$createConsumer(dest) conn$start() msg <- cons$receive() System$out$println(msg) conn$close()
W/ Durability
import(java.lang.System) import(javax.jms.Session) import(org.apache.activemq.ActiveMQConnectionFactory) connFactory <- ActiveMQConnectionFactory$new() conn <- connFactory$createConnection() conn$setClientID("SampleClient") sess <- conn$createSession(FALSE, Session$AUTO_ACKNOWLEDGE) dest <- sess$createTopic("SampleTopic") cons <- sess$createDurableSubscriber(dest, "SampleSubscription") conn$start() msg <- cons$receive() System$out$println(msg) conn$close()
Leave a comment