From 35f6d0df839854fbaa7e0470be2c675dbd9e2d95 Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@vmware.com>
Date: Tue, 15 Mar 2011 15:33:06 +0000
Subject: [PATCH] AMQP-121: change concurrency attribute parsing

---
 .../amqp/rabbit/config/ListenerContainerParser.java             | 2 +-
 .../amqp/rabbit/config/ListenerContainerParserTests-context.xml | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerParser.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerParser.java
index 4842aea0..bc3530f2 100644
--- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerParser.java
+++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerParser.java
@@ -203,7 +203,7 @@ class ListenerContainerParser implements BeanDefinitionParser {
 
 		String concurrency = containerEle.getAttribute(CONCURRENCY_ATTRIBUTE);
 		if (StringUtils.hasText(concurrency)) {
-			containerDef.getPropertyValues().add("concurrency", concurrency);
+			containerDef.getPropertyValues().add("concurrentConsumers", concurrency);
 		}
 
 		String prefetch = containerEle.getAttribute(PREFETCH_ATTRIBUTE);
diff --git a/spring-rabbit/src/test/resources/org/springframework/amqp/rabbit/config/ListenerContainerParserTests-context.xml b/spring-rabbit/src/test/resources/org/springframework/amqp/rabbit/config/ListenerContainerParserTests-context.xml
index a406e26a..59bf766e 100644
--- a/spring-rabbit/src/test/resources/org/springframework/amqp/rabbit/config/ListenerContainerParserTests-context.xml
+++ b/spring-rabbit/src/test/resources/org/springframework/amqp/rabbit/config/ListenerContainerParserTests-context.xml
@@ -9,7 +9,7 @@
 
 	<rabbit:queue name="bar" />
 
-	<rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual">
+	<rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual" concurrency="5">
 		<rabbit:listener id="testListener" queue-names="foo, bar" ref="testBean" method="handle"/>
 	</rabbit:listener-container>