该整合实例是在maven项目中整合，先要构建一个maven项目

第一步在maven项目的pom.xml文件中导入依赖

<!--这些依赖都是activemq和spring整合需要的依赖-->
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jms</artifactId>
</dependency>

<!-- xbean 如<amq:connectionFactory /> -->
<dependency>
    <groupId>org.apache.xbean</groupId>
    <artifactId>xbean-spring</artifactId>
    <version>3.16</version>
</dependency>

<!-- activemq -->
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-core</artifactId>
    <version>5.7.0</version>
</dependency>
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-pool</artifactId>
</dependency>

第二步，在spring的core配置文件中配置

<!--接收和发送的配置是一样的-->
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:jms="http://www.springframework.org/schema/jms"
	xsi:schemaLocation="
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
		http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.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">
	
	<!-- 配置连接工厂 -->
	<amq:connectionFactory id="activeConnectionFactory" brokerURL="tcp://127.0.0.1:61616" userName="admin" password="admin" />
	<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
		<constructor-arg ref="activeConnectionFactory" />
		<property name="sessionCacheSize" value="100" />
	</bean>

	<!-- 配置目的地 -->
	<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg index="0" value="FirstQueue" />
	</bean>

	<!-- 配置JmsTemplate -->
	<bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="defaultDestination" ref="queueDestination" />
		<property name="receiveTimeout" value="10000" />
		<!-- true是topic，false是queue，默认是false，此处显示写出false -->
		<property name="pubSubDomain" value="false" />
	</bean>
</beans>

第三步、使用junit测试

//消息发送
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(value = "classpath:/spring/spring-core.xml")
public class Sender {

	@Resource(name = "JmsTemplate")
	private JmsTemplate jmsTemplate;

	@Test
	public void test() {
		System.out.println(jmsTemplate);
		System.out.println("向" + jmsTemplate.getDefaultDestination().toString() + "发送消息");
		jmsTemplate.send(new MessageCreator() {
			@Override
			public Message createMessage(Session session) throws JMSException {
				return session.createTextMessage("发送消息");
			}
		});

	}
}

//消息接收
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(value = "classpath:/spring/spring-core.xml")
public class Consumer {

	@Resource(name = "JmsTemplate")
	private JmsTemplate jmsTemplate;

	@Resource(name = "queueDestination")
	private Destination destination;

	@Test
	public void test() {
		System.out.println(jmsTemplate);
		TextMessage message = (TextMessage) jmsTemplate.receive(destination);
		try {
			System.out.println("接受消息>>>>>>>>>>>" + message.getText());
		} catch (JMSException e) {
			e.printStackTrace();
		}
	}
}

注意：使用MessageListener接收信息的配置

1、实现一个Message监听器
package com.web.consumer;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class demoMessageListener implements MessageListener {

	@Override
	public void onMessage(Message message) {
		try {
			System.out.println("接受到消息>>>>>>>>"+((TextMessage)message).getText());
		} catch (JMSException e) {
			e.printStackTrace();
		}
	}

}

2、在配置文件中添加如下配置
<bean id="demoMessageListener" class="com.web.consumer.demoMessageListener" />

<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
	<property name="connectionFactory" ref="connectionFactory" />
	<property name="destination" ref="queueDestination" />
	<property name="messageListener" ref="demoMessageListener" />
</bean>