W/o Durability
require 'java' connFactory = org.apache.activemq.ActiveMQConnectionFactory.new conn = connFactory.createConnection sess = conn.createSession(false, javax.jms.Session::AUTO_ACKNOWLEDGE) dest = sess.createTopic('SampleTopic') cons = sess.createConsumer(dest) conn.start msg = cons.receive puts msg conn.close
W/ Durability
require 'java' connFactory = org.apache.activemq.ActiveMQConnectionFactory.new conn = connFactory.createConnection conn.clientID = 'SampleClient' sess = conn.createSession(false, javax.jms.Session::AUTO_ACKNOWLEDGE) dest = sess.createTopic('SampleTopic') cons = dest.createDurableSubscriber(dest, 'SampleSubscription') conn.start msg = cons.receive puts msg conn.close