import javax.jms { Connection, ConnectionFactory, Destination, Message, MessageConsumer, Session } import org.apache.activemq { ActiveMQConnectionFactory } void main() { ConnectionFactory connFactory = ActiveMQConnectionFactory(); Connection conn = connFactory.createConnection(); Session sess = conn.createSession(false, Session.\iAUTO_ACKNOWLEDGE); Destination dest = sess.createQueue("SampleQueue"); MessageConsumer cons = sess.createConsumer(dest); conn.start(); Message msg = cons.receive(); print(msg); conn.close(); }