首页 > 代码库 > 初学Activemq,写了一个和spring一起的配置文件

初学Activemq,写了一个和spring一起的配置文件

1:数据库使用dbcp配置。

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
  <property name="driverClassName" value="http://www.mamicode.com/${jdbc.driverClassName}" />
  <property name="url" value="http://www.mamicode.com/${jdbc.url}" />
  <property name="username" value="http://www.mamicode.com/${jdbc.username}" />
  <property name="password" value="http://www.mamicode.com/${jdbc.password}" />
  <property name="minPoolSize" value="http://www.mamicode.com/${jdbc.minPoolSize}"/>
  <property name="maxPoolSize" value="http://www.mamicode.com/${jdbc.maxPoolSize}"/>
  <property name="initialPoolSize" value="http://www.mamicode.com/${jdbc.initialPoolSize}"/>

  <!--最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。默认为0 -->
  <property name="maxIdleTime" value="http://www.mamicode.com/${jdbc.maxIdleTime}"/>
</bean>

2:配置connectionFactory 链接工厂
<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
  <property name="connectionFactory">
  <bean class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="http://www.mamicode.com/${activemq.url}"/>
  </bean>
  </property>
  <property name="maxConnections" value="http://www.mamicode.com/${activemq.maxConnections}"></property>
</bean>

 

3:将mq的模式设置为queue,实现异步接收。

<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">

  <constructor-arg index="0" value="http://www.mamicode.com/${activemq.destination}"></constructor-arg>
</bean>

4:你的消费者实现类,处理接收消息的主函数。
<bean id="consumer" class="com.myself.jms.msgaccepter.action.ConsumerAction">
  <property name="" ref=""></property>
</bean>

5:消息监听容器,这里统一实现了actinmq的消息接收机制。
<bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
  <property name="concurrentConsumers" value="http://www.mamicode.com/${activemq.consumers}" />
  <property name="connectionFactory" ref="jmsFactory" />
  <property name="destination" ref="destination" />
  <property name="messageListener" ref="consumer" />
</bean>

 

6:$内的值通过properties文件记录,支持更改。

初学Activemq,写了一个和spring一起的配置文件