NASA再次进入北极,结果看到了这样的景象、、、

W/o Durability

(define-alias Session javax.jms.Session)

(define-alias ActiveMQConnectionFactory org.apache.activemq.ActiveMQConnectionFactory)

(define connFactory (ActiveMQConnectionFactory:new))

(define conn (connFactory:createConnection))

(define sess (conn:createSession #f Session:AUTO_ACKNOWLEDGE))

(define dest (sess:createTopic "SampleTopic"))

(define cons (sess:createConsumer dest))

(conn:start)

(define msg (cons:receive))

(display msg)

(conn:close)

W/ Durability

(define-alias Session javax.jms.Session)

(define-alias ActiveMQConnectionFactory org.apache.activemq.ActiveMQConnectionFactory)

(define connFactory (ActiveMQConnectionFactory:new))

(define conn (connFactory:createConnection))

(conn:setClientID "SampleClient")

(define sess (conn:createSession #f Session:AUTO_ACKNOWLEDGE))

(define topic (sess:createTopic "SampleTopic"))

(define cons (sess:createDurableSubscriber topic "SampleSubscription"))

(conn:start)

(define msg (cons:receive))

(display msg)

(conn:close)