<?xml version="1.0" encoding="UTF-8"?>
<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-->
<!-- START SNIPPET: spring -->
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!-- an embedded broker -->
<bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
<property name="config" value="classpath:org/apache/activemq/xbean/activemq.xml" />
</bean>
<!-- JMS ConnectionFactory to use -->
<bean id="jmsFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61636"/>
</bean>
<!-- Spring JMS Template -->
<bean id="myJmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<!-- lets wrap in a pool to avoid creating a connection per send -->
<bean
class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="jmsFactory" />
</bean>
</property>
</bean>
<bean id="consumerJmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactory"/>
</bean>
<!-- a sample POJO which uses a Spring JmsTemplate -->
<bean id="producer" class="org.apache.activemq.spring.SpringProducer">
<property name="template" ref="myJmsTemplate" />
<property name="destination" ref="destination" />
<property name="messageCount" value="10" />
</bean>
<!-- a sample POJO consumer -->
<bean id="consumer" class="org.apache.activemq.spring.SpringConsumer">
<property name="template" ref="consumerJmsTemplate" />
<property name="destination" ref="destination" />
</bean>
<bean id="destination" class="org.apache.activemq.command.ActiveMQTopic"
autowire="constructor">
<constructor-arg value="org.apache.activemq.spring.Test.spring.topic" />
</bean>
</beans>
<!-- END SNIPPET: spring -->
分享到:
相关推荐
Spring 集成 IBM MQ 监听配置,包括用户管理配置和一些基础配置信息
在“springmq”这个项目中,我们可以看到一个完整的Spring MVC与ActiveMQ的整合示例。项目包含了Spring MVC的配置、ActiveMQ的配置、消息监听器的实现,以及发送和接收消息的控制器。通过这个项目,开发者可以学习...
在Spring配置中,我们可以定义一个ConnectionFactory,它是与MQ服务器通信的工厂类。接着,我们可以创建一个Destination(队列或主题),并配置MessageListenerContainer,监听MQ中的消息。 2. **Spring配置...
本示例聚焦于Spring框架与Apache ActiveMQ的整合,旨在帮助开发者更好地理解和实现Spring与MQ的无缝集成,从而提升系统的稳定性和效率。 首先,我们需要理解Spring框架。Spring是Java领域最流行的轻量级开源框架之...
而在Spring中,我们可以通过XML配置文件动态地管理这些对象和它们的属性,如上面的代码片段所示,配置了`MQConnectionFactory`和`MQQueue`,并为发送和接收消息的组件提供了引用。 发送JMS消息的步骤在Spring中通常...
【 Maven Spring MQ 集成详解 】 在Java开发中,消息队列(Message Queue,简称MQ)是一种常用于解耦系统组件、提高系统可扩展性的技术。本篇将深入探讨如何利用Maven构建项目,并结合Spring框架集成ActiveMQ,以...
当我们需要在Spring应用中集成ActiveMQ时,就需要进行相应的配置。本文将深入讲解ActiveMQ与Spring的整合配置方案。 首先,我们需要在项目中引入ActiveMQ的相关依赖。这通常通过在`pom.xml`文件中添加Maven依赖来...
3. **配置Spring**:在Spring的配置文件(如applicationContext.xml)中,你需要配置JMS相关的bean,包括连接工厂、目的地(Queue或Topic)以及消息监听容器。例如: ```xml ...
这个Demo项目展示了如何在Spring应用中配置和使用IBM MQ 7.5版本,确保了其兼容性和有效性。 首先,我们需要理解Spring框架的核心概念。Spring是一个开源的应用框架,它提供了一个全面的编程和配置模型,用于创建...
Spring集成ActiveMQ配置详解 Spring框架与ActiveMQ的集成,为开发者提供了一种高效、可靠的JMS消息处理机制。在企业级应用中,这种集成能够极大地提升系统的响应速度和容错能力,特别是在需要异步通信和分布式事务...
在本文中,我们将深入探讨如何使用Spring AMQP配置来实现RabbitMQ的路由。Spring AMQP是Spring框架的一个模块,它提供了与RabbitMQ消息中间件集成的能力,使得在Java应用中处理AMQP(Advanced Message Queuing ...
当我们谈到“activityMQ调用示例,spring集成示例”,这意味着我们将探讨如何将ActivityMQ与Spring框架整合,以实现高效、可扩展的系统架构。 首先,我们需要理解ActivityMQ的核心概念。ActivityMQ是一个基于Apache...
2) 使用SPRING BOOT Conditional机制实现了两种产品按需加载,工程会根据配置文件开关动态加载 3) 实现了普通队列消息发送与监听,实现了基于TOPIC的消息发布与订阅 4) IBM-MQ无需提前创建主题,TongLink需要提前...
本项目"springboot-集成MQ"旨在教你如何将MQ集成到Spring Boot工程中,这对于新手来说是一个很好的学习资源。 首先,我们需要了解MQ的基本概念。MQ是一种异步通信机制,允许应用程序之间通过消息进行通信,而无需...
这个"消息中间件-spring-MQ.zip"压缩包很可能包含了一个关于如何在Spring框架中集成和使用消息中间件的示例项目,名为"spring-MQ-main"。 首先,我们需要理解什么是消息中间件。消息中间件是用于应用程序之间通信的...
"SPRING-MVC-MQ-CXF-REST_Demo"这个项目很可能是用来演示如何在同一个应用中整合Spring MVC、MQ、CXF和REST技术。项目可能包含了以下部分: 1. Spring MVC配置:展示了如何设置DispatcherServlet、视图解析器以及...
2. **创建配置**:在Spring的配置文件(如`applicationContext.xml`)中,定义RabbitMQ的相关配置,包括连接工厂、交换机、队列和绑定关系。例如: ```xml <bean id="rabbitConnectionFactory" class="org.spring...
这个特性使得Spring应用能够实现组件间的异步通信,类似于消息队列(MQ)的工作模式。下面我们将深入探讨Spring的`ApplicationContext`如何实现事件监听以及其在实际开发中的应用。 首先,`ApplicationContext`的...
标题中的“Spring MQ集成”指的是在Spring框架中整合消息队列(Message Queue)技术,通常是指使用Spring的Integration模块或Spring Boot的Starter for Apache ActiveMQ来实现消息传递功能。ActiveMQ是Apache软件...