jmsqueuesender.java

Spring2.0宝典

package lee;

import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.JmsTemplate102;
import org.springframework.jms.core.MessageCreator;

/**
 * @author  yeeku.H.lee [e-mail]
 * @version  1.0
 * <br>Copyright (C), 2005-2008, yeeku.H.Lee
 * <br>This program is protected by copyright laws.
 * <br>Program Name:
 * <br>Date: 
 */

public class JmsQueueSender
{
	private JmsTemplate jt;
	private ConnectionFactory connFactory;
	private Queue queue;
	public void setConnectionFactory(ConnectionFactory cf)
	{
		connFactory = cf;
	}
	public void setQueue(Queue q)
	{
		queue = q;
	}


	public void simpleSend()
	{
		jt = new JmsTemplate102(connFactory, false);
		jt.send(queue, new MessageCreator()
		{
			public Message createMessage(Session session) throws JMSException {
			return session.createTextMessage("hello queue world");
		}
		});
	}

}