import org.jboss.mq.beans.MessageHelper; String textMessage = "Hello, JBossMQ!"; javax.jms.TextMessage text = session.createTextMessage(textMessage); javax.jms.Message xml = MessageHelper.convertToXMLMessage(text); import org.jboss.mq.SelectorEvaluator; String selector = "age >= 18"; SelectorEvaluator selectorEvaluator = new SelectorEvaluator(selector); while (true) { javax.jms.Message message = consumer.receive(); if (selectorEvaluator.isValid(message)) { // ... } } import org.jboss.mq.ServerSessionPool; ServerSessionPool sessionPool = new ServerSessionPool(serverSession); ServerSession serverSession1 = sessionPool.getServerSession(queue1); ServerSession serverSession2 = sessionPool.getServerSession(queue2); while (true) { javax.jms.Message message = consumer.receive(); int priority = message.getJMSPriority(); if (priority > 5) { serverSession1.send(queue1, message); } else { serverSession2.send(queue2, message); } }