spring interation学习-01发送jms消息

1.程序概述

使用spring-interation来实现将一个消息发送到activeMQ的消息队列中-需要安装activeMQ并在上面新建一个名称为queue.hello的队列

2.工程依赖添加

这里我们用的是maven管理，把spring相关的jar包搞到工程中来

package com.haier.mdm.message;import java.text.SimpleDateFormat;import java.util.Date;import javax.jms.Queue;import org.junit.After;import org.junit.Before;import org.junit.Test;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.integration.MessageChannel;import org.springframework.integration.message.GenericMessage;public class JmsTest {private ClassPathXmlApplicationContext applicationContext;@Beforepublic void setUp(){applicationContext = new ClassPathXmlApplicationContext("/applicationContext-activeMQ.xml");applicationContext.start();}@Testpublic void testChannel(){MessageChannel messageChannel = applicationContext.getBean("jmsChannel", MessageChannel.class);GenericMessage<String> message = new GenericMessage<String>("使用message channel 发送"+generateTimeString());for(int i = 0; i<100; i ++)    messageChannel.send(message);}private String generateTimeString(){return new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());}@Afterpublic void tearDown(){applicationContext.stop();}}