W/o Durability
java_object('org.apache.activemq.ActiveMQConnectionFactory', [], ConnFactory), ConnFactory <- createConnection returns Conn, class('javax.jms.Session').'AUTO_ACKNOWLEDGE' <- get(AutoAcknowledge), Conn <- createSession(false, AutoAcknowledge) returns Sess, Sess <- createTopic('SampleTopic') returns Dest, Sess <- createConsumer(Dest) returns Cons, Conn <- start, Cons <- receive returns Msg, class('java.lang.System').out <- get(Out), Out <- println(Msg), Conn <- close.
W/ Durability
java_object('org.apache.activemq.ActiveMQConnectionFactory', [], ConnFactory), ConnFactory <- createConnection returns Conn, Conn <- setClientID('SampleClient'), class('javax.jms.Session').'AUTO_ACKNOWLEDGE' <- get(AutoAcknowledge), Conn <- createSession(false, AutoAcknowledge) returns Sess, Sess <- createTopic('SampleTopic') returns Dest, Sess <- createDurableSubscriber(Dest, 'SampleSubscription') returns Cons, Conn <- start, Cons <- receive returns Msg, class('java.lang.System').out <- get(Out), Out <- println(Msg), Conn <- close.