How to Receive a Message from an Apache ActiveMQ Topic with SISC

W/o Durability

(import s2j)

(define-java-class <javax.jms.session>)

(define-java-class <org.apache.activemq.active-m-q-connection-factory>)

(define connFactory (java-new <org.apache.activemq.active-m-q-connection-factory> ()))

(define createConnection (generic-java-method '|createConnection|))

(define conn (createConnection connFactory))

(define createSession (generic-java-method '|createSession|))

(define autoAcknowledge (generic-java-field-accessor '|AUTO_ACKNOWLEDGE|))

(define sess (createSession conn (->jboolean #f) (autoAcknowledge (java-null <javax.jms.session>))))

(define createTopic (generic-java-method '|createTopic|))

(define dest (createTopic sess (->jstring "SampleTopic")))

(define createConsumer (generic-java-method '|createConsumer|))

(define cons (createConsumer sess dest))

(define start (generic-java-method '|start|))

(start conn)

(define receive (generic-java-method '|receive|))

(define msg (receive cons))

(display msg)

(define close (generic-java-method '|close|)) 

(close conn)

W/ Durability

(import s2j)

(define-java-class <javax.jms.session>)

(define-java-class <org.apache.activemq.active-m-q-connection-factory>)

(define connFactory (java-new <org.apache.activemq.active-m-q-connection-factory>))

(define createConnection (generic-java-method '|createConnection|))

(define conn (createConnection connFactory))

(define setClientID (generic-java-method '|setClientID|))

(setClientID conn (->jstring "SampleClient"))

(define createSession (generic-java-method '|createSession|))

(define autoAcknowledge (generic-java-field-accessor '|AUTO_ACKNOWLEDGE|))

(define sess (createSession conn (->jboolean #f) (autoAcknowledge (java-null <javax.jms.session>))))

(define createTopic (generic-java-method '|createTopic|))

(define topic (createTopic sess (->jstring "SampleTopic")))

(define createDurableSubscriber (generic-java-method '|createDurableSubscriber|))

(define cons (createDurableSubscriber sess topic (->jstring "SampleSubscription")))

(define start (generic-java-method '|start|))

(start conn)

(define receive (generic-java-method '|receive|))

(define msg (receive cons))

(display msg)

(define close (generic-java-method '|close|)) 

(close conn)