<!-- ActiveMQ的依赖 -->
<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-core</artifactId><version>5.5.0</version>
</dependency>
<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-client</artifactId><version>5.13.1</version>
</dependency>
<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-pool</artifactId><version>5.13.1</version>
</dependency>
<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-broker</artifactId><version>5.13.1</version>
</dependency><!-- ActiveMQ+Spring的依赖 -->
<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-spring</artifactId><version>5.12.2</version>
</dependency>
<dependency><groupId>org.springframework</groupId><artifactId>spring-jms</artifactId><version>4.1.9.RELEASE</version>
</dependency>

<?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"default-autowire="byName"><!--第一步： 配置connectionFactory -->  <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  <property name="brokerURL" value="tcp://localhost:61616"/> <property name="userName"  value="admin"/><property name="password"  value="admin"/>  </bean>  <bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">  <property name="connectionFactory" ref="targetConnectionFactory"/> <property name="maxConnections" value="10"/>  </bean>  <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">  <property name="targetConnectionFactory" ref="pooledConnectionFactory"/>  </bean>  <!--第二步：配置JmsTemplate之消息生产者 --><bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">  <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  <property name="connectionFactory" ref="connectionFactory"/>  </bean>  <!--队列目的地，点对点-->  <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">  <constructor-arg value="queue"/>  </bean>  <!--主题目的地，订阅发布-->  <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">  <constructor-arg value="topic"/> </bean>  <!--第三步：配置JmsTemplate之消息消费者 --><!-- 消息监听器 -->  <bean id="consumerMessageListener" class="com.zte.ems.springjms.listener.ConsumerMessageListener"/> <!-- com.zte.ems.springjms.listener.ConsumerMessageListener这个类是自己创建的，实现MessageListener 接口 --> <!-- 消息监听容器 -->  <bean id="jmsContainer"  class="org.springframework.jms.listener.DefaultMessageListenerContainer">  <property name="connectionFactory" ref="connectionFactory" />  <property name="queue_destination" ref="queueDestination" /><property name="topic_destination" ref="topicDestination" />  <property name="messageListener" ref="consumerMessageListener" />  </bean>
</beans>

package com.zte.ems.springjim.listener;
import javax.jms.Message;
import javax.jms.MessageListener;
public class ConsumerMessageListener implements MessageListener {public void onMessage(Message arg0) {// 这里我们就是监听生产者发送过来的消息，然后进行处理
    }
}