学习activemq,在spring中activemq的配置信息

提供者:

<?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:jms="http://www.springframework.org/schema/jms"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:amq="http://activemq.apache.org/schema/core"
 xsi:schemaLocation="
  http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/jms
  http://www.springframework.org/schema/jms/spring-jms.xsd
  http://activemq.apache.org/schema/core
  http://activemq.apache.org/schema/core/activemq-core.xsd
  http://www.springframework.org/schema/context
  http://www.springframework.org/schema/context/spring-context.xsd">

<!-- 需要创建一个连接工厂,连接ActiveMQ. ActiveMQConnectionFactory. 需要依赖ActiveMQ提供的amq标签 -->
 <!-- amq:connectionFactory 是bean标签的子标签, 会在spring容器中创建一个bean对象. 可以为对象命名.
  类似: <bean id="" class="ActiveMQConnectionFactory"></bean> -->
 <amq:connectionFactory brokerURL="tcp://192.168.46.131:61616" password="admin"
 userName="admin"  id="amqconnectionFactory">
 </amq:connectionFactory> 
 <!-- 配置池化的ConnectionFactory。 为连接ActiveMQ的connectionFactory提供连接池 -->
 <bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactoryBean">
 <property name="connectionFactory" ref="amqconnectionFactory"></property>
 <property name="maxConnections" value="5"></property>
 </bean>
 <!-- spring管理JMS相关代码的时候,必须依赖jms标签库. spring-jms提供的标签库. -->
 <!-- 定义Spring-JMS中的连接工厂对象 CachingConnectionFactory - spring框架提供的连接工厂对象.
  不能真正的访问MOM容器. 类似一个工厂的代理对象. 需要提供一个真实工厂,实现MOM容器的连接访问. -->
 <!-- 配置有缓存的ConnectionFactory,session的缓存大小可定制。 -->
 <bean id="cachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
 <property name="targetConnectionFactory" ref="pooledConnectionFactory"></property>
 <property name="sessionCacheSize" value="3"></property>
 </bean>

<!-- JmsTemplate配置 -->
 <bean id="template" class="org.springframework.jms.core.JmsTemplate">
  <!-- 给定连接工厂, 必须是spring创建的连接工厂. -->
  <property name="connectionFactory" ref="cachingConnectionFactory"></property>
  <!-- 可选 - 默认目的地命名 -->
  <property name="defaultDestinationName" value="test-spring"></property>
 </bean>
</beans>

消费者:

<?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:jms="http://www.springframework.org/schema/jms"
 xmlns:amq="http://activemq.apache.org/schema/core"
 xsi:schemaLocation="
  http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/jms
  http://www.springframework.org/schema/jms/spring-jms.xsd
  http://activemq.apache.org/schema/core
  http://activemq.apache.org/schema/core/activemq-core.xsd">
 <!-- 需要创建一个连接工厂,连接ActiveMQ. ActiveMQConnectionFactory. 需要依赖ActiveMQ提供的amq标签 -->
 <!-- amq:connectionFactory 是bean标签的子标签, 会在spring容器中创建一个bean对象.
  可以为对象命名. 类似: <bean id="" class="ActiveMQConnectionFactory"></bean>
  -->
 <amq:connectionFactory brokerURL="tcp://192.168.46.131:61616"
  userName="admin" password="admin" id="amqConnectionFactory"/>

<!-- spring管理JMS相关代码的时候,必须依赖jms标签库. spring-jms提供的标签库. -->
 <!-- 定义Spring-JMS中的连接工厂对象
  CachingConnectionFactory - spring框架提供的连接工厂对象. 不能真正的访问MOM容器.
   类似一个工厂的代理对象. 需要提供一个真实工厂,实现MOM容器的连接访问.
  -->
 <bean id="connectionFactory"
  class="org.springframework.jms.connection.CachingConnectionFactory">
  <property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
  <property name="sessionCacheSize" value="3"></property>
 </bean>
 
 <!-- 注册监听器 -->
 <!-- 开始注册监听.
  需要的参数有:
   acknowledge - 消息确认机制
   container-type - 容器类型 default|simple
   simple:SimpleMessageListenerContainer最简单的消息监听器容器,只能处理固定数量的JMS会话,且不支持事务。
   default:DefaultMessageListenerContainer是一个用于异步消息监听器容器 ,且支持事务        
   destination-type - 目的地类型. 使用队列作为目的地.
   connection-factory - 连接工厂, spring-jms使用的连接工厂,必须是spring自主创建的
   不能使用三方工具创建的工程. 如: ActiveMQConnectionFactory.
  -->
 <jms:listener-container acknowledge="auto" container-type="default"
  destination-type="queue" connection-factory="connectionFactory" >
  <!-- 在监听器容器中注册某监听器对象.
   destination - 设置目的地命名
   ref - 指定监听器对象
   -->
  <jms:listener destination="test-spring" ref="myListener"/>
 </jms:listener-container>
 
</beans>

其实差异并没啥区别,多注册了一个监听

原文地址:https://www.cnblogs.com/MTAngel/p/10981843.html

时间: 2024-08-07 02:14:24

学习activemq,在spring中activemq的配置信息的相关文章

spring中MessageSource的配置使用方法1[转]

本文转载仅供自己学习收录,不做任何商业用途,如有需要请访问文章原地址:http://blog.csdn.net/qyf_5445/article/details/8124306 Spring定义了访问国际化信息的MessageSource接口,并提供了几个易用的实现类.首先来了解一下该接口的几个重要方法:?  String getMessage(String code, Object[] args, String defaultMessage, Locale locale) code表示国际化资

spring中MessageSource的配置使用方法3--ResourceBundleMessageSource【转】

本文转载仅供自己学习收录,不做任何商业用途,如有需要请访问原地址:http://blog.csdn.net/qyf_5445/article/details/8124431 ApplicationContext接口扩展了MessageSource接口,因而提供了消息处理的功能(i18n或者国际化).与HierarchicalMessageSource一起使用,它还能够处理嵌套的消息,这些是spring提供的处理消息的基本接口.让我们快速浏览一下它所定义的方法: String getMessage

关于spring中&lt;context:annotation-config/&gt;配置

在spring的配置文件中,如果我们一个一个地配置bean会非常麻烦,因此我们可以使用注解的方式 使用@Autowired注解,必须事先在Spring容器中声明AutowiredAnnotationBeanPostProcessor的Bean: 使用 @Required注解,就必须声明RequiredAnnotationBeanPostProcessor的Bean 类似地,使用@Resource.@PostConstruct.@PreDestroy等注解就必须声明 CommonAnnotatio

Spring中Quartz的配置

软件152苏锐 Quartz是一个强大的企业级任务调度框架,Spring中继承并简化了Quartz,下面就看看在Spring中怎样配置Quartz:首先我们来写一个被调度的类: package com.kay.quartz;public class QuartzJob{ public void work()    {    System.out.println("Quartz的任务调度!!!");    }} Spring的配置文件: <?xml version="1.

Spring 中的 Bean 配置

内容提要 •IOC & DI 概述 •配置 bean –配置形式:基于 XML 文件的方式:基于注解的方式 –Bean 的配置方式:通过全类名(反射).通过工厂方法(静态工厂方法 & 实例工厂方法).FactoryBean –IOC 容器 BeanFactory & ApplicationContext 概述 –依赖注入的方式:属性注入:构造器注入 –注入属性值细节 –自动转配 –bean 之间的关系:继承:依赖 –bean 的作用域:singleton:prototype:WEB

利用spring中的Log4jConfigListener配置log4j

1.编辑好log4j的配置文件,可以为xml也可以是properties. 2.在web.xml中分别配置context-param标签和spring中log4j配置监听器,如下:

Spring中常用的配置和注解详解

一.  Spring中常用的配置文件详解 Spring中的配置文件详解 1.<!-- 配置注解bean的扫描路径 该配置表示从cn包下开始扫描--> <context:component-scan base-package="cn"></context:component-scan> 2.<!-- 加载资源文件 其中Location表示从哪个路径加载配置文件properties--> <context:property-placeh

spring中MessageSource的配置使用方法3--ResourceBundleMessageSource

ApplicationContext接口扩展了MessageSource接口,因而提供了消息处理的功能(i18n或者国际化).与HierarchicalMessageSource一起使用,它还能够处理嵌套的消息,这些是Spring提供的处理消息的基本接口.让我们快速浏览一下它所定义的方法: String getMessage(String code, Object[] args, String default, Locale loc):用来从MessageSource获取消息的基本方法.如果在指

Quartz 在 Spring 中如何动态配置时间--转

原文地址:http://www.iteye.com/topic/399980 在项目中有一个需求,需要灵活配置调度任务时间,并能自由启动或停止调度. 有关调度的实现我就第一就想到了Quartz这个开源调度组件,因为很多项目使用过,Spring结合Quartz静态配置调度任务时间,非常easy.比如:每天凌晨几点定时运行一个程序,这只要在工程中的spring配置文件中配置好spring整合quartz的几个属性就好. Spring配置文件 引用 <bean id="jobDetail&quo