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