Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQP-121: change concurrency attribute parsing

Browse Source
This commit is contained in:
Dave Syer
2011-03-15 15:33:06 +00:00
parent 5c4d13ca26
commit 35f6d0df83
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerParser.java
View File

@@ -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);

2
spring-rabbit/src/test/resources/org/springframework/amqp/rabbit/config/ListenerContainerParserTests-context.xml
View File

@@ -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>