W/o Durability
library("rJava") .jinit() attach(javaImport(c("java.lang", "javax.jms", "org.apache.activemq"))) connFactory <- new(ActiveMQConnectionFactory) 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
library("rJava") .jinit() attach(javaImport(c("java.lang", "javax.jms", "org.apache.activemq"))) connFactory <- new(ActiveMQConnectionFactory) conn <- connFactory$createConnection() conn$setClientID("SampleClient") sess <- conn$createSession(FALSE, Session$AUTO_ACKNOWLEDGE) topic <- sess$createTopic("SampleTopic") cons <- sess$createDurableSubscriber(topic, "SampleSubscription") conn$start() msg <- cons$receive() System$out$println(msg) conn$close()