W/o Durability
from javax.jms import Session from org.apache.activemq import ActiveMQConnectionFactory connFactory = 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
from javax.jms import Session from org.apache.activemq import ActiveMQConnectionFactory connFactory = 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()