JMS与SPRING的整合实例（基于Apache ActiveMQ）

/*=================================================== * File:Publisher.java * Created:[2012-8-24 上午9:42:58] by lixu *=================================================== * Project:JMS_new * Package:com.bekiz.jms * <p>Description:</p> *==================================================== * Copyright:bekiz.tongyiku * Version:1.0 *===================================================*/ package com.bekiz.jms; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Scanner; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.Session; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; /** * <p>Class:Publisher</p> * <p>Description:</p> * @author lixu * @Date [2012-8-24 上午9:42:58] */ public class Publisher { private JmsTemplate jmsTemplate ; private Destination destinations; public void setDestinations(Destination destinations) { this.destinations = destinations; } public void setJmsTemplate(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } // 发布 public void publisher(){ while (true){ jmsTemplate.send(destinations,new MessageCreator(){ @Override public MapMessage createMessage(Session session) throws JMSException { MapMessage message = session.createMapMessage(); Scanner cin = new Scanner(System.in); String msg =cin.nextLine(); String date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); message.setString("id", "ming"); message.setString("message", msg); message.setString("date", date); return message; } }); } } }