RestQueueLauncher.java

package com.redhat.demo.msg.web;

import java.net.InetAddress;

import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.XAConnection;
import javax.jms.XAConnectionFactory;
import javax.jms.XASession;
import javax.naming.InitialContext;
import javax.transaction.TransactionManager;
import javax.ws.rs.GET;
import javax.ws.rs.Path;

@Path("/restqueue")
public class RestQueueLauncher {
	@GET
	public String testQueue() {
		try {
			InitialContext ic = new InitialContext();
			XAConnectionFactory cf = (XAConnectionFactory) ic.lookup("XAConnectionFactory");
			TransactionManager tm = (TransactionManager)ic.lookup("java:/TransactionManager");
			tm.begin();
			XAConnection conn = cf.createXAConnection();
			conn.start();
			XASession sess = conn.createXASession();
			Queue queue = (Queue) ic.lookup("/queue/WorkQueue");
			MessageProducer producer = sess.createProducer(queue);
			InetAddress addr = InetAddress.getLocalHost();
			producer.send(sess.createTextMessage("Test Message : "
					+ addr.getHostName()));
			producer.close();
			conn.close();
			sess.close();
			tm.commit();
			System.out.println("Message sent.");
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "SUCCESS";
	}
}