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

INT-959 added test for concurrency settings on a JMS-backed channel

Browse Source
This commit is contained in:
Mark Fisher
2010-03-12 17:14:52 +00:00
parent 0ae71b84f5
commit 9c1af74519
2 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests-context.xml
View File

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

14
org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/config/JmsChannelParserTests.java
View File

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