SpringMVC集成rabbitMQ

Maven引入相关jar
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.2.4</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-amqp</artifactId>
<version>2.1.3.RELEASE</version>
</dependency>

spring-mq.xml

<?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"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">
<context:property-placeholder location="classpath:jdbc.properties,classpath:config.properties" />
<bean id="rabbitClientConnectionFactory" class="com.rabbitmq.client.ConnectionFactory">
<property name="host" value="127.0.0.1"/>
<property name="port" value="5672" />
<property name="username" value="guest" />
<property name="password" value="guest" />
<!--    <property name="connectionTimeout" value="10000" />   -->
</bean>
<!-- 连接服务配置 -->
<rabbit:connection-factory id="rabbitConnectionFactory"  connection-factory="rabbitClientConnectionFactory"/>
<rabbit:admin connection-factory="rabbitConnectionFactory" />
<!-- queue 队列声明 -->
<rabbit:queue id="jimmy-request-queue" durable="true" auto-delete="false" exclusive="false" name="jimmy-request-queue" />
<!--   exchange queue binging key 绑定 -->
<rabbit:direct-exchange name="jimmy-queue-exchange" durable="true" auto-delete="false" id="jimmy-queue-exchange">
<rabbit:bindings>
<rabbit:binding queue="jimmy-request-queue" key="jimmy-request-queue" />
</rabbit:bindings>
</rabbit:direct-exchange>

<!--   spring template声明 -->
<rabbit:template exchange="jimmy-queue-exchange"   id="amqpTemplate"  connection-factory="rabbitConnectionFactory"  />
<!-- queue litener  观察 监听模式 当有消息到达时会通知监听在对应的队列上的监听对象 -->
<rabbit:listener-container connection-factory="rabbitConnectionFactory" acknowledge="auto" >
<rabbit:listener queues="jimmy-request-queue" ref="foo" method="handleRequestMessage" />
</rabbit:listener-container>

</beans>

生产者

public void thrwosmq(){
amqpTemplate.convertAndSend("jimmy-request-queue","ddd");
System.out.println("asdf");
}
消费者

public class Foo {

public void handleRequestMessage(String aaa) {
System.out.println(aaa);
}

}