jmsqueuereceiver.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 javax.jms.TextMessage;

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 JmsQueueReceiver
{

	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 simpleReceive()throws Exception
	{
		jt = new JmsTemplate102(connFactory, false);
		TextMessage tm = (TextMessage)jt.receive(queue);
		System.out.println(tm.getText());
	}



}