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