import javax.jms.Session import org.apache.activemq.ActiveMQConnectionFactory final class ActiveMQSample { def static void main(String[] args) { val connFactory = new ActiveMQConnectionFactory() val conn = connFactory.createConnection() val sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE) val dest = sess.createQueue("SampleQueue") val prod = sess.createProducer(dest) val msg = sess.createTextMessage("Simples Assim") prod.send(msg) conn.close() } }