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