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() }
How to Receive a Message from an Apache ActiveMQ Queue with Kotlin
百度 目前,活动平台已经在人民网《地方领导留言板》上线。
Leave a comment