太原明确2018年十项房管重点工作

W/o Durability

(def connFactory (new org.apache.activemq.ActiveMQConnectionFactory))

(def conn (.createConnection connFactory))

(def sess (.createSession conn false, javax.jms.Session/AUTO_ACKNOWLEDGE))

(def dest (.createTopic sess "SampleTopic"))

(def cons (.createConsumer sess dest))

(.start conn)

(def msg (.receive cons))

(println msg)

(.close conn)

W/ Durability

(def connFactory (new org.apache.activemq.ActiveMQConnectionFactory))

(def conn (.createConnection connFactory))

(.setClientID conn "SampleClient")

(def sess (.createSession conn false, javax.jms.Session/AUTO_ACKNOWLEDGE))

(def topic (.createTopic sess "SampleTopic"))

(def cons (.createDurableSubscriber sess topic, "SampleSubscription"))

(.start conn)

(def msg (.receive cons))

(println msg)

(.close conn)