public class ActivemqTest extends TestCase {
@Test
public void testJmsTemplateSend() {
ApplicationContext ctx = new ClassPathXmlApplicationContext(
"/applicationContext-jms.xml");
JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");
Destination destination = (Destination) ctx.getBean("destination");
template.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session
.createTextMessage("发送消息:Hello ActiveMQ Text Message!");
}
});
System.out.println("成功发送了一条JMS消息");
}
@Test
public void testJmsTemplateReceive() throws JMSException {
ApplicationContext ctx = new ClassPathXmlApplicationContext(
"/applicationContext-jms.xml");
JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");
Destination destination = (Destination) ctx.getBean("destination");
while (true) {
TextMessage txtmsg = (TextMessage) template.receive(destination);
if (null != txtmsg)
System.out.println("收到消息内容为: " + txtmsg.getText());
else
break;
}
}
}
applicationContext-jms.xml文件:
Java代码 收藏代码
<?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:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-2.5.xsd">
<!-- 配置JMS连接工厂 -->
<bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
<!-- 配置JMS模版 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
<!-- 发送消息的目的地(一个队列) -->
<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- Set the Queue Name -->
<constructor-arg index="0" value="HelloWorldQueue"/>
</bean>
</beans>
特殊的jar
Java代码 收藏代码
activemq-core-5.2.0.jar
geronimo-j2ee-management_1.0_spec-1.0.jar
spring-jms-2.5.5.jar
xbean-spring-3.4.jar
分享到:
相关推荐
activeMQ与spring整合开发的例子程序,消息队列技术
ActiveMq流程并结合Spring应用
学习jms+active+spring过程中自己写的一些简单例子,详情可见博文http://blog.csdn.net/dream_broken/article/details/43759911
Spring boot 和内置ActiveMQ集成例子,通过代码学习Spring boot 和内置ActiveMQ集成。
spring集成activemq例子demo
spring boot activemq整合例子
http://blog.csdn.net/live501837145/article/details/46532159 代码实例
Spring+ActiveMQ active基本例子 注解的完整实例,包含jar包
springMVC整合activeMQ的例子
ActiveMQ入门例子,有三个小Demo,有简单的说明,具体下载看项目吧。
SpringBoot+ActiveMq+MQTT实现消息的发送和接收 后台消费者、生产者、消息发送接口、发送消息业务类等相关配置
spring boot 集成activemq Datajpa Ehcache 里面有详细的例子
NULL 博文链接:https://zhaoshijie.iteye.com/blog/2090954
我上面有个activemq的集群例子,这里有activemq_in_action、activemq_spring、activemq_集群。及相关配置。如果有这方面的需要给以给我留言。
包含activemq的安装包,JMS(java message service)的开发例子,java开发以及集成spring的开发,包含点对点与发布/订阅两种模式
这是一个简单的Spring JMS template例子,通过ActiveMQ中转消息,实现了发送和接收消息的基本功能 测试方法: 1:下载 ActiveMQ,并启动 2: 分别运行MessageReciver和MessageSender
一个active和spring整合的例子,方便大家在做项目的时候有个例子可以参考
java的开源消息队列activeMQ的学习例子demo。有详细注释,springJMS消息队列。
jms 案例对于初学者很有用的偶,很简单很使用的例子
activemq-jms-spring 关于ActiveMQ,这是一个简单的示例。