import javax.jms.Session import org.apache.activemq.ActiveMQConnectionFactory fun main(args : Array<String>) { val connFactory = ActiveMQConnectionFactory() val conn = connFactory.createConnection()!! val sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE)!! val dest = sess.createQueue("SampleQueue") val cons = sess.createConsumer(dest)!! conn.start() val msg = cons.receive() println(msg) conn.close() }