1.程序概述
使用spring-interation来实现将一个消息发送到activeMQ的消息队列中-需要安装activeMQ并在上面新建一个名称为queue.hello的队列
2.工程依赖添加
这里我们用的是maven管理,把spring相关的jar包搞到工程中来
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.crazycoder2010</groupId>
<artifactId>casclient</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>casclient Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<spring.integration.version>2.2.6.RELEASE</spring.integration.version>
<activemq.version>5.7.0</activemq.version>
<slf4j.version>1.7.5</slf4j.version>
<spring.version>3.2.4.RELEASE</spring.version>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>${activemq.version}</version>
<exclusions>
<exclusion>
<artifactId>spring-context</artifactId>
<groupId>org.springframework</groupId>
</exclusion>
<exclusion>
<artifactId>slf4j-api</artifactId>
<groupId>org.slf4j</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>${spring.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-core</artifactId>
<version>${spring.integration.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-jms</artifactId>
<version>${spring.integration.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
</dependencies>
<build>
<finalName>casclient</finalName>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>1.7</source>
<target>1.7</target>
<encoding>UTF-8</encoding>
</configuration>
</plugin>
</plugins>
</build>
</project>
3.编写配置文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.org/schema/integration" xmlns:jms="http://www.springframework.org/schema/integration/jms"
xmlns:stream="http://www.springframework.org/schema/integration/stream"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/integration/jms
http://www.springframework.org/schema/integration/jms/spring-integration-jms.xsd
http://www.springframework.org/schema/integration/stream
http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd">
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
<bean id="helloQueue" class="org.apache.activemq.command.ActiveMQQueue" autowire="constructor">
<constructor-arg value="queue.hello" />
</bean>
<jms:channel id="jmsChannel"
connection-factory="connectionFactory"
queue="helloQueue"
message-driven="false"> <!--一定注意将这个属性设置为false,否则报无订阅者的异常-->
</jms:channel>
</beans>
4.编写发送测试程序
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;
@Before
public void setUp(){
applicationContext = new ClassPathXmlApplicationContext("/applicationContext-activeMQ.xml");
applicationContext.start();
}
@Test
public 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());
}
@After
public void tearDown(){
applicationContext.stop();
}
}
分享到:
相关推荐
弹簧集成样品 Spring 集成示例 编辑 2
722-interation4 722中的国际代码4
实现了强化学习中的策略迭代方法,对于强化学习的初学者来说很有帮助。
UML簡介 1-1UML簡介 1-2使用者案例 1-2-1解構使用者案例 1-3類別圖Class Diagrams 1-4互動圖Interation Diagrams 1-5狀態圖State Diagrams 1-6活動圖Activity Diagrams 1-7套件 1-8UML軟體 1-8-1安裝JUDE
1.2分析1.2.1 KPI的兑换率 (%) 在来宾与主人之间的不同沟通阶段,从first interation -> first reply -> acceptance -> booking/abandoned 各种联系渠道类型(contact_me,book_it,instant_book) 跨用户类型...
SUMS45 Game Theory -- Decisions, Interaction and Evolution, James N. Webb (2007).zip
Iteration of rational functions by Alan F. Beardon (z-lib.org).pdf
Chapter 11:Interation:Reverse Differentiation Chapter 12:Integration Rules for Calculus Conmoi sseurs Chapter 13:Who Needs Freud? Using the Integral to Solve Your Problems Chapter 14:Infinite (Sort of...
钱包我的算法 Keyreg 蓝绿色标志 .../*Warning: Browser will block pop-up if user doesn't trigger myAlgoWallet.connect() with a button interation */ const connectToMyAlgo = async ( ) => { try {
EA AquaLogic BSI(Business Service Interation) Studio是流程开发人员的工作台,囊括BEA AquaLogic BSI Designer的全部功能,并添加大量工具,允许开发人员编写业务逻辑,连接到现有应用程序,组装供人员交互的用户界面...
simulate the motion due to the gravitational interation of a system that cosists of 3 objects 输出轨迹图和运动模拟图
节点启动器开始项目npm installswagger project start项目中有什么承诺承诺全部CouchDb Interation(可以与IBM的Cloudant一起使用) 使用请求的REST调用带有API密钥的Swagger安全性./config/application_config.js中...
2. 1 CTI(computer telephony interation) 2.1.1 CTI 的概念 2.1.2 CTI 的主要标准协议 2.1.3 CTI 技术的重要应用 2.2 ACD (Automatic Call Distributor ) 2.2.1 交换机和排队机的区别 2.2.2 ACD 的主要功能 ...