Add ingegration test for RedisManagerPool

Author: mythz

tests/ServiceStack.Redis.Tests/Integration/IntegrationTestBase.cs

@@ -10,13 +10,21 @@ namespace ServiceStack.Redis.Tests.Integration
     [Category("Integration")]
 	public class IntegrationTestBase
 	{
-		protected IRedisClientsManager CreateAndStartPoolManager(
-			string[] readWriteHosts, string[] readOnlyHosts)
-		{
-			return new PooledRedisClientManager(readWriteHosts, readOnlyHosts);
-		}
+        protected IRedisClientsManager CreateAndStartPoolManager(
+            string[] readWriteHosts, string[] readOnlyHosts)
+        {
+            return new PooledRedisClientManager(readWriteHosts, readOnlyHosts);
+        }
+
+        protected IRedisClientsManager CreateAndStartManagerPool(
+            string[] readWriteHosts, string[] readOnlyHosts)
+        {
+            return new RedisManagerPool(readWriteHosts, new RedisPoolConfig {
+                MaxPoolSize = 10
+            });
+        }
 
-		protected IRedisClientsManager CreateAndStartBasicCacheManager(
+        protected IRedisClientsManager CreateAndStartBasicCacheManager(
 			string[] readWriteHosts, string[] readOnlyHosts)
 		{
 			return new BasicRedisClientManager(readWriteHosts, readOnlyHosts);

tests/ServiceStack.Redis.Tests/Integration/MultiThreadedPoolIntegrationTests.cs

@@ -38,11 +38,17 @@ public void Pool_can_support_64_threads_using_the_client_simultaneously()
 			RunSimultaneously(CreateAndStartManager, UseClient);
 		}
 
-		[Test]
-		public void Basic_can_support_64_threads_using_the_client_simultaneously()
-		{
-			RunSimultaneously(CreateAndStartBasicManager, UseClient);
-		}
+        [Test]
+        public void Basic_can_support_64_threads_using_the_client_simultaneously()
+        {
+            RunSimultaneously(CreateAndStartBasicManager, UseClient);
+        }
+
+        [Test]
+        public void ManagerPool_can_support_64_threads_using_the_client_simultaneously()
+        {
+            RunSimultaneously(CreateAndStartManagerPool, UseClient);
+        }
 
 		private static void UseClient(IRedisClientsManager manager, int clientNo)
 		{