messageproducter.java

Spring2.0宝典

/*******************************************************************
<br>Copyright (C), 2004-2006, yeeku.H.Lee
<br>Program Name:MessageProducter.java
<br>作用：演示队列消息生产者程序
<br>Author:yeeku.H.lee [e-mail]
<br>Version:1.0
<br>This program is protected by copyright laws.
<br>Date: 2005-9-22
*******************************************************************/

package leejms;

import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.NamingException;
import javax.naming.InitialContext;
import java.util.Properties;

public final class MessageProducter
{
    private QueueSender sender;
	private TextMessage msg;
    public MessageProducter()throws NamingException,JMSException
	{
		Context ctx = getInitialContext();
		QueueConnectionFactory qConFactory = (QueueConnectionFactory)ctx.lookup("weblogic.jms.ConnectionFactory"); 
		Queue messageQueue = (Queue)ctx.lookup("MessageQueue");
        System.out.println(messageQueue);
		QueueConnection qCon = qConFactory.createQueueConnection();
		QueueSession session = qCon.createQueueSession(false,/*不是事务性会话*/Session.AUTO_ACKNOWLEDGE);
		sender = session.createSender(messageQueue);
		msg = session.createTextMessage();
		//msg.setStringProperty("ConType","txt");
    }
	 
	public void sendMessage()throws JMSException
	{
		msg.setText("Hello");
		sender.send(msg);
		msg.setText("Welcome to JMS");
		sender.send(msg);
	}
//----------------公用函数，用来获取命名服务的Context对象-------------------------
    protected Context getInitialContext()
	{
        String url = "t3://localhost:8181";
	    Properties properties = null;
		Context ctx=null;
		try
		{
			Properties p = new Properties();
			p.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
			p.put(Context.PROVIDER_URL, url);
			ctx = new InitialContext(p);
		}
		catch(NamingException ne)
		{
			System.err.println("不能连到WebLogic server在" +url);
			ne.printStackTrace();
		}
		return ctx;
	}
    //------------------------主函数，程序的入口-----------------------------
    public static void main(String[] args)throws Exception
	{
		MessageProducter mp = new MessageProducter();
		mp.sendMessage();
	}
}