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

AMQP-107 added test for queue names in addition to queue instances

Browse Source
This commit is contained in:
Mark Fisher
2011-03-28 16:40:15 -04:00
parent 800da7475d
commit 5bd1b9303c
1 changed files with 24 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerMultipleQueueIntegrationTests.java
View File

@@ -66,6 +66,24 @@ public class MessageListenerContainerMultipleQueueIntegrationTests {
@Test
public void testMultipleQueues() {
doTest(new ContainerConfigurer() {
public void configure(SimpleMessageListenerContainer container) {
container.setQueues(queue1, queue2);
}
});
}
@Test
public void testMultipleQueueNames() {
doTest(new ContainerConfigurer() {
public void configure(SimpleMessageListenerContainer container) {
container.setQueueNames(queue1.getName(), queue2.getName());
}
});
}
private void doTest(ContainerConfigurer configurer) {
int messageCount = 10;
int concurrentConsumers = 1;
RabbitTemplate template = new RabbitTemplate();
@@ -87,7 +105,7 @@ public class MessageListenerContainerMultipleQueueIntegrationTests {
container.setAcknowledgeMode(AcknowledgeMode.AUTO);
container.setChannelTransacted(true);
container.setConcurrentConsumers(concurrentConsumers);
container.setQueueNames(queue1.getName(), queue2.getName());
configurer.configure(container);
container.afterPropertiesSet();
container.start();
try {
@@ -110,6 +128,11 @@ public class MessageListenerContainerMultipleQueueIntegrationTests {
}
private interface ContainerConfigurer {
void configure(SimpleMessageListenerContainer container);
}
@SuppressWarnings("unused")
private static class PojoListener {