queuemessagetest.java

这个是学习EJB的好例子,里面有许多关于EJB Bean的

package com.cws.ejb.message;

import java.util.Properties;

import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;

public class QueueMessageTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		QueueConnection conn = null;
		QueueSender sender = null;
		QueueSession session = null;
		Queue queue = null;

		try {
			Properties props = new Properties();
			props.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
			props.setProperty("java.naming.provider.url", "localhost:1099");
			props.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
			InitialContext ctx = new InitialContext(props);

			QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
			conn = factory.createQueueConnection();
			session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
			queue = (Queue) ctx.lookup("queue/cwsQueue");
			
			TextMessage msg = session.createTextMessage("这是我的第一个队列式消息驱动Bean");
			sender = session.createSender(queue);
			sender.send(msg);
			session.close();
		}
		catch (Exception e) {
			System.out.println(e.getMessage());
		}	

	}

}