diff --git a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Config/MessageListenerContainerObjectDefinitionParser.cs b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Config/MessageListenerContainerObjectDefinitionParser.cs index bab73576..e84985d8 100644 --- a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Config/MessageListenerContainerObjectDefinitionParser.cs +++ b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Config/MessageListenerContainerObjectDefinitionParser.cs @@ -293,7 +293,7 @@ namespace Spring.Messaging.Ems.Config string concurrency = ParseConcurrency(containerElement, parserContext); if (concurrency != null) { - containerDef.AddPropertyValue("ConcurrentConsumers", concurrency[1]); + containerDef.AddPropertyValue("ConcurrentConsumers", concurrency); } containerDef.AddPropertyValue("RecoveryInterval", ParseRecoveryInterval(containerElement, parserContext)); diff --git a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Listener/SimpleMessageListenerContainer.cs b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Listener/SimpleMessageListenerContainer.cs index 65611f2b..31a68a4b 100644 --- a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Listener/SimpleMessageListenerContainer.cs +++ b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Listener/SimpleMessageListenerContainer.cs @@ -105,7 +105,11 @@ namespace Spring.Messaging.Ems.Listener set { AssertUtils.IsTrue(value > 0, "'ConcurrentConsumer' value must be at least 1 (one)"); - concurrentConsumers = value; + concurrentConsumers = value; + } + get + { + return concurrentConsumers; } } diff --git a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.cs b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.cs index 9094f26e..1df63c33 100644 --- a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.cs +++ b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.cs @@ -90,6 +90,7 @@ namespace Spring.Messaging.Ems.Config else if (container.ConnectionFactory.Equals(explicitConnectionFactory)) { explicitConnectionFactoryCount++; + Assert.AreEqual(4, container.ConcurrentConsumers); } } diff --git a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.xml b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.xml index eae42752..8fa14ae4 100644 --- a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.xml +++ b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Messaging/Ems/Config/EmsNamespaceHandlerTests.xml @@ -1,19 +1,19 @@  + xmlns:ems="http://www.springframework.net/ems"> - - - + - + - - - + + + @@ -44,7 +44,7 @@ - + diff --git a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.csproj b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.csproj index 00147ac9..0a6fe1ce 100644 --- a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.csproj +++ b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.csproj @@ -93,7 +93,9 @@ - + + Always + diff --git a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.dll.config b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.dll.config index 53fa88de..02c51dd3 100644 --- a/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.dll.config +++ b/test/Spring/Spring.Messaging.Ems.Integration.Tests/Spring.Messaging.Ems.Integration.Tests.dll.config @@ -1,14 +1,26 @@  + +
+
+ type="log4net.Config.Log4NetConfigurationSectionHandler,log4net" /> + + + + + + + +