W/o Durability
connFactory = .bsf~new('org.apache.activemq.ActiveMQConnectionFactory') conn = connFactory~createConnection() sess = conn~createSession(.false, bsf.getConstant('javax.jms.Session', 'AUTO_ACKNOWLEDGE')) dest = sess~createTopic('SampleTopic') cons = sess~createConsumer(dest) conn~bsf.invoke('start') msg = cons~receive() say msg conn~close() ::requires 'BSF.CLS'
W/ Durability
connFactory = .bsf~new('org.apache.activemq.ActiveMQConnectionFactory') conn = connFactory~createConnection() conn~setClientID('SampleClient') sess = conn~createSession(.false, bsf.getConstant('javax.jms.Session', 'AUTO_ACKNOWLEDGE')) dest = sess~createTopic('SampleTopic') cons = sess~createDurableSubscriber(dest, 'SampleSubscription') conn~bsf.invoke('start') msg = cons~receive() say msg conn~close() ::requires 'BSF.CLS'
Leave a comment