From 9c1af7451979172c64c1b490a4185d420fb04eec Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Fri, 12 Mar 2010 17:14:52 +0000
Subject: [PATCH] INT-959 added test for concurrency settings on a JMS-backed
 channel

---
 .../jms/config/JmsChannelParserTests-context.xml   |  2 ++
 .../jms/config/JmsChannelParserTests.java          | 14 ++++++++++++++
 2 files changed, 16 insertions(+)

diff --git a/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests-context.xml b/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests-context.xml
index 0751b80ecb..102853cb98 100644
--- a/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests-context.xml
+++ b/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests-context.xml
@@ -21,6 +21,8 @@
 	<jms:publish-subscribe-channel id="topicNameWithResolverChannel" topic-name="foo"
 			     destination-resolver="destinationResolver" connection-factory="connFact"/>
 
+	<jms:channel id="channelWithConcurrencySettings" queue-name="foo" concurrency="11-55"/>
+
 	<bean id="testQueue" class="org.apache.activemq.command.ActiveMQQueue">
 		<property name="physicalName" value="test.queue"/>
 	</bean>
diff --git a/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests.java b/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests.java
index 6e4384a688..005ef75195 100644
--- a/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests.java
+++ b/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests.java
@@ -33,6 +33,7 @@ import org.springframework.integration.core.MessageChannel;
 import org.springframework.integration.jms.JmsDestinationBackedMessageChannel;
 import org.springframework.jms.core.JmsTemplate;
 import org.springframework.jms.listener.AbstractMessageListenerContainer;
+import org.springframework.jms.listener.DefaultMessageListenerContainer;
 import org.springframework.jms.support.destination.DestinationResolver;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@@ -65,6 +66,9 @@ public class JmsChannelParserTests {
 	@Autowired
 	private MessageChannel topicNameWithResolverChannel;
 
+	@Autowired
+	private MessageChannel channelWithConcurrencySettings;
+
 	@Autowired
 	private Topic topic;
 
@@ -135,6 +139,16 @@ public class JmsChannelParserTests {
 		assertEquals("foo", container.getDestinationName());
 	}
 
+	@Test
+	public void channelWithConcurrencySettings() {
+		assertEquals(JmsDestinationBackedMessageChannel.class, channelWithConcurrencySettings.getClass());
+		JmsDestinationBackedMessageChannel channel = (JmsDestinationBackedMessageChannel) channelWithConcurrencySettings;
+		DirectFieldAccessor accessor = new DirectFieldAccessor(channel);
+		DefaultMessageListenerContainer container = (DefaultMessageListenerContainer) accessor.getPropertyValue("container");
+		assertEquals(11, container.getConcurrentConsumers());
+		assertEquals(55, container.getMaxConcurrentConsumers());
+	}
+
 
 	static class TestDestinationResolver implements DestinationResolver {