import javax.jms.Session import org.apache.activemq.ActiveMQConnectionFactory connFactory = ActiveMQConnectionFactory.new conn = connFactory.createConnection sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE) dest = sess.createQueue('SampleQueue') cons = sess.createConsumer(dest) conn.start() msg = cons.receive() puts msg conn.close()