package com.jms.message; 

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

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

/** 
 * 
 * 发送消息
 * @author Administrator 
 * @version create time：2013年11月5日 下午1:02:52 
 * 
 */
public class MessageSender {
	
	private JmsTemplate jmsTemplate;
	
	public final void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	
	
	public void sendMessage(final String message){
		jmsTemplate.send(new MessageCreator() {
			
			@Override
			public Message createMessage(Session session) throws JMSException {
				TextMessage textMessage = (TextMessage)session.createTextMessage(message);
				return textMessage;
			}
		});
	}
}