甩开攻略 为你挖掘旅客眼中看不到的鼓浪屿

W/o Durability

uses javax.jms.Session

uses org.apache.activemq.ActiveMQConnectionFactory

var connFactory = new ActiveMQConnectionFactory()

var conn = connFactory.createConnection()

var sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)

var dest = sess.createTopic('SampleTopic')

var cons = sess.createConsumer(dest)

conn.start()

var msg = cons.receive()

print(msg)

conn.close()

W/ Durability

uses javax.jms.Session

uses org.apache.activemq.ActiveMQConnectionFactory

var connFactory = new ActiveMQConnectionFactory()

var conn = connFactory.createConnection()

conn.ClientID = 'SampleClient'

var sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)

var dest = sess.createTopic('SampleTopic')

var cons = sess.createDurableSubscriber(dest, 'SampleSubscription')

conn.start()

var msg = cons.receive()

print(msg)

conn.close()