W/o Durability
Session = javax.jms.Session ActiveMQConnectionFactory = org.apache.activemq.ActiveMQConnectionFactory 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() print(msg) conn.close()
W/ Durability
Session = javax.jms.Session ActiveMQConnectionFactory = org.apache.activemq.ActiveMQConnectionFactory connFactory = new ActiveMQConnectionFactory() conn = connFactory.createConnection() conn.clientID = 'SampleClient' sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE) dest = sess.createTopic('SampleTopic') cons = sess.createDurableSubscriber(dest, 'SampleSubscription') conn.start() msg = cons.receive() print(msg) conn.close()