From 27efb67420cc958e11cdca4271e1ac4a4b52788c Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Mon, 28 Mar 2011 16:48:10 -0400
Subject: [PATCH] AMQP-107 added tests for concurrent consumers

---
 ...ontainerMultipleQueueIntegrationTests.java | 27 +++++++++++++++----
 1 file changed, 22 insertions(+), 5 deletions(-)

diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerMultipleQueueIntegrationTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerMultipleQueueIntegrationTests.java
index 3864cb70..6f47f6db 100644
--- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerMultipleQueueIntegrationTests.java
+++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerMultipleQueueIntegrationTests.java
@@ -66,7 +66,7 @@ public class MessageListenerContainerMultipleQueueIntegrationTests {
 
 	@Test
 	public void testMultipleQueues() {
-		doTest(new ContainerConfigurer() {
+		doTest(1, new ContainerConfigurer() {
 			public void configure(SimpleMessageListenerContainer container) {
 				container.setQueues(queue1, queue2);
 			}
@@ -75,7 +75,25 @@ public class MessageListenerContainerMultipleQueueIntegrationTests {
 
 	@Test
 	public void testMultipleQueueNames() {
-		doTest(new ContainerConfigurer() {
+		doTest(1, new ContainerConfigurer() {
+			public void configure(SimpleMessageListenerContainer container) {
+				container.setQueueNames(queue1.getName(), queue2.getName());
+			}
+		});
+	}
+
+	@Test
+	public void testMultipleQueuesWithConcurrentConsumers() {
+		doTest(3, new ContainerConfigurer() {
+			public void configure(SimpleMessageListenerContainer container) {
+				container.setQueues(queue1, queue2);
+			}
+		});
+	}
+
+	@Test
+	public void testMultipleQueueNamesWithConcurrentConsumers() {
+		doTest(3, new ContainerConfigurer() {
 			public void configure(SimpleMessageListenerContainer container) {
 				container.setQueueNames(queue1.getName(), queue2.getName());
 			}
@@ -83,12 +101,11 @@ public class MessageListenerContainerMultipleQueueIntegrationTests {
 	}
 
 
-	private void doTest(ContainerConfigurer configurer) {
+	private void doTest(int concurrentConsumers, ContainerConfigurer configurer) {
 		int messageCount = 10;
-		int concurrentConsumers = 1;
 		RabbitTemplate template = new RabbitTemplate();
 		CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
-		connectionFactory.setChannelCacheSize(1);
+		connectionFactory.setChannelCacheSize(concurrentConsumers);
 		connectionFactory.setPort(BrokerTestUtils.getPort());
 		template.setConnectionFactory(connectionFactory);
 		SimpleMessageConverter messageConverter = new SimpleMessageConverter();